MCPcopy Create free account

hub / github.com/alibaba/DataX / functions

Functions5,539 in github.com/alibaba/DataX

⨍ Functions 5,539◇ Types & classes 1,122
↓ 7 callersMethodsetState
(State state, boolean isForce)
core/src/main/java/com/alibaba/datax/core/statistics/communication/Communication.java:67
↓ 7 callersMethodtransferObjectForJson
(Object o,DataType type)
cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderHelper.java:71
↓ 7 callersMethodwriteCheckpoint
(long timestamp, ShardCheckpoint checkpoint)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/core/CheckpointTimeTracker.java:236
↓ 6 callersMethodasDate
(final StringColumn column)
common/src/main/java/com/alibaba/datax/common/element/ColumnCast.java:92
↓ 6 callersMethodasString
()
core/src/main/java/com/alibaba/datax/core/statistics/plugin/task/util/DirtyRecord.java:124
↓ 6 callersMethodbuild
()
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/HbaseColumnCell.java:120
↓ 6 callersMethodbuild
()
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/DirectLoaderBuilder.java:135
↓ 6 callersMethodcheckString
(Object value, String error)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/WriterModelParser.java:40
↓ 6 callersMethodcheckStringAndGet
(Configuration param, String key)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/ParamChecker.java:41
↓ 6 callersMethodcheckStringEmpty
(String value, String error)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/WriterModelParser.java:47
↓ 6 callersMethodcolumnGetObject
(Map<String, Object> column, String key, String error)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/WriterModelParser.java:30
↓ 6 callersMethodcompareObVersion
compare two ob versions @param version1 @param version2 @return 0 when the two versions are the same -1 when version1 is smaller (earlier) than versi
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/ObReaderUtils.java:870
↓ 6 callersMethodcompleteMultipartUpload
( final CompleteMultipartUploadRequest currentCompleteMultipartUploadRequest)
osswriter/src/main/java/com/alibaba/datax/plugin/writer/osswriter/OssWriterProxy.java:67
↓ 6 callersMethoddefaultValue
(T defaultValue)
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/config/Option.java:22
↓ 6 callersMethodexecuteBatch
(List<AbstractInsertTask> tasks)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/WriterThreadPool.java:33
↓ 6 callersMethodexecuteUpdate
(String sql, int autoGeneratedKeys)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:454
↓ 6 callersMethodfromShortName
(final String name)
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/mapping/ValueType.java:46
↓ 6 callersMethodgetColumns
()
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/Keys.java:92
↓ 6 callersMethodgetColumns
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/config/OTSStreamReaderConfig.java:171
↓ 6 callersMethodgetCombineFields
()
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/ElasticSearchColumn.java:51
↓ 6 callersMethodgetCompatibleMode
(Connection conn)
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/ObReaderUtils.java:805
↓ 6 callersMethodgetCurrentBlockId
()
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/OdpsWriterProxy.java:191
↓ 6 callersMethodgetDataType
()
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/ads/ColumnInfo.java:39
↓ 6 callersMethodgetDbNameFromJdbcUrl
(String jdbcUrl)
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/ObReaderUtils.java:830
↓ 6 callersMethodgetEnableAutoIncrement
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:160
↓ 6 callersMethodgetEndOffset
()
ossreader/src/main/java/com/alibaba/datax/plugin/reader/ossreader/util/OssSplitUtil.java:467
↓ 6 callersMethodgetFullUserName
()
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/ext/ServerConnectInfo.java:97
↓ 6 callersMethodgetLoadProps
()
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/Keys.java:115
↓ 6 callersMethodgetLoadProps
()
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/StarRocksWriterOptions.java:137
↓ 6 callersMethodgetMode
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:141
↓ 6 callersMethodgetMode
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:139
↓ 6 callersMethodgetOriginalType
(org.apache.parquet.schema.Type type, Map<String, ParquetMeta> parquetMetaMap)
hdfsreader/src/main/java/com/alibaba/datax/plugin/reader/hdfsreader/DFSUtil.java:955
↓ 6 callersMethodgetParas
()
core/src/main/java/com/alibaba/datax/core/transport/transformer/TransformerExecutionParas.java:27
↓ 6 callersMethodgetPeerPluginJobConf
()
common/src/main/java/com/alibaba/datax/common/plugin/Pluginable.java:20
↓ 6 callersMethodgetPkColumns
(Connection conn, TaskContext context)
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/ObReaderUtils.java:153
↓ 6 callersMethodgetPrecision
()
common/src/main/java/com/alibaba/datax/common/element/DateColumn.java:50
↓ 6 callersMethodgetPrimaryKeyColumns
()
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/ads/TableInfo.java:127
↓ 6 callersMethodgetProperties
()
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/GdbElement.java:45
↓ 6 callersMethodgetQuerySql
()
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/TaskContext.java:82
↓ 6 callersMethodgetResultsFromSql
@param conn @param sql @return
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/ObReaderUtils.java:884
↓ 6 callersMethodgetRetryPauseInMillisecond
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:83
↓ 6 callersMethodgetScale
()
hbase11xsqlwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xsqlwriter/ThinClientPTable.java:391
↓ 6 callersMethodgetTable
()
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/Keys.java:74
↓ 6 callersMethodgetTable
()
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/StarRocksWriterOptions.java:94
↓ 6 callersMethodgetTableInfo
Obtain the table meta information. @param table The table @return The table meta information @throws com.alibaba.datax.plugin.writer.adswriter.AdsExc
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/load/AdsHelper.java:86
↓ 6 callersMethodgetTags
()
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/QueryResult.java:33
↓ 6 callersMethodgetTotalReadBytes
(final Communication communication)
core/src/main/java/com/alibaba/datax/core/statistics/communication/CommunicationTool.java:88
↓ 6 callersMethodgetValue
()
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/reader/ColumnEntry.java:42
↓ 6 callersMethodgetValue
()
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/DataPoint4TSDB.java:56
↓ 6 callersMethodinitiateMultipartUpload
( final InitiateMultipartUploadRequest currentInitiateMultipartUploadRequest)
osswriter/src/main/java/com/alibaba/datax/plugin/writer/osswriter/OssWriterProxy.java:56
↓ 6 callersMethodisThinClient
()
hbase11xsqlwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xsqlwriter/HbaseSQLWriterConfig.java:90
↓ 6 callersMethodisTimeseriesTable
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:181
↓ 6 callersMethodlimit
(String name, long limit, LoggerFunction function)
common/src/main/java/com/alibaba/datax/common/util/LimitLogger.java:16
↓ 6 callersMethodloadJobPlugin
加载JobPlugin，reader、writer都可能要加载 @param pluginType @param pluginName @return
core/src/main/java/com/alibaba/datax/core/util/container/LoadUtil.java:91
↓ 6 callersMethodparseFromString
(String s, DataType sqlType )
cassandrawriter/src/main/java/com/alibaba/datax/plugin/writer/cassandrawriter/CassandraWriterHelper.java:46
↓ 6 callersMethodreport
(Integer taskid, Communication communication)
core/src/main/java/com/alibaba/datax/core/taskgroup/TaskMonitor.java:43
↓ 6 callersMethodsetName
(String name)
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/ads/ColumnInfo.java:35
↓ 6 callersMethodsetPeerPluginName
(String peerPluginName)
common/src/main/java/com/alibaba/datax/common/plugin/Pluginable.java:28
↓ 6 callersMethodsetSchemaManager
(SchemaManager schemaManager)
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java:55
↓ 6 callersMethodsetTableMetas
(Map<String, TableMeta> tableMetas)
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java:47
↓ 6 callersMethodsetTbnameColumnMetasMap
(Map<String, List<ColumnMeta>> tbnameColumnMetasMap)
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java:51
↓ 6 callersMethodsetThrowable
(Throwable throwable)
core/src/main/java/com/alibaba/datax/core/statistics/communication/Communication.java:87
↓ 6 callersMethodtake
(FileBlock fileBlock)
ossreader/src/main/java/com/alibaba/datax/plugin/reader/ossreader/util/OssSplitUtil.java:299
↓ 6 callersMethodtoInt
()
common/src/main/java/com/alibaba/datax/common/statistics/PerfRecord.java:63
↓ 6 callersMethoduploadOnePart
对于同一个UploadID，该号码不但唯一标识这一块数据，也标识了这块数据在整个文件内的相对位置。 如果你用同一个part号码，上传了新的数据，那么OSS上已有的这个号码的Part数据将被覆盖。 @throws Exception
osswriter/src/main/java/com/alibaba/datax/plugin/writer/osswriter/OssWriter.java:1129
↓ 6 callersMethodwriteOneRecord
(List<String> splitedRows)
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/writer/UnstructuredWriter.java:9
↓ 6 callersMethodwriterPreCheck
(Configuration originalConfig, DataBaseType dataBaseType)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/CommonRdbmsWriter.java:49
↓ 5 callersMethodaddBatch
Copy a new row data avoid overwrite. @throws SQLException
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/DirectPathPreparedStatement.java:59
↓ 5 callersMethodaddColumn
(Column column)
neo4jwriter/src/test/java/com/alibaba/datax/plugin/writer/mock/MockRecord.java:27
↓ 5 callersMethodappendJDBCSuffixForReader
(String jdbc)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DataBaseType.java:45
↓ 5 callersFunctionattributeNotNone
(obj, attributes)
core/src/main/bin/perftrace.py:149
↓ 5 callersMethodcancel
()
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:554
↓ 5 callersMethodcheckStringAndGet
(Configuration param, String key, boolean isTrim)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/ParamChecker.java:20
↓ 5 callersMethodclone
()
core/src/main/java/com/alibaba/datax/core/statistics/communication/Communication.java:156
↓ 5 callersMethodcloseTable
(HTable table)
hbase094xwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase094xwriter/Hbase094xHelper.java:136
↓ 5 callersMethodcreateAdsHelper
(Configuration originalConfig)
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/util/AdsUtil.java:57
↓ 5 callersMethodcreateSupAndSubTable
()
tdenginewriter/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandlerTest.java:266
↓ 5 callersMethodexecuteWithRetry
(Callable<V> callable, int maxRetryTimes, int sleepInMilliSecond)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/RetryHelper.java:18
↓ 5 callersMethodexpandTableConf
(DataBaseType dataBaseType, List<String> tables)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/TableExpandUtil.java:72
↓ 5 callersMethodflush
()
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/writer/UnstructuredWriter.java:11
↓ 5 callersMethodgetAdsConnect
(Configuration conf)
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/util/AdsUtil.java:168
↓ 5 callersMethodgetCapacity
()
ossreader/src/main/java/com/alibaba/datax/plugin/reader/ossreader/util/OssSplitUtil.java:305
↓ 5 callersMethodgetClassLoader
()
core/src/main/java/com/alibaba/datax/core/transport/transformer/TransformerInfo.java:23
↓ 5 callersMethodgetColumn
(Object value)
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/TSDBDump.java:186
↓ 5 callersMethodgetColumnType
()
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/HbaseColumnCell.java:65
↓ 5 callersMethodgetConcurrencyWrite
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:63
↓ 5 callersMethodgetData
()
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/BaseResponse.java:20
↓ 5 callersMethodgetESFieldType
(String type)
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/ElasticSearchFieldType.java:37
↓ 5 callersMethodgetElapsedTimeInNs
()
common/src/main/java/com/alibaba/datax/common/statistics/PerfRecord.java:208
↓ 5 callersMethodgetFilledLenght
()
ossreader/src/main/java/com/alibaba/datax/plugin/reader/ossreader/util/OssSplitUtil.java:313
↓ 5 callersMethodgetFrom
()
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/GdbEdge.java:21
↓ 5 callersMethodgetIndexName
(Configuration conf)
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/Key.java:87
↓ 5 callersMethodgetLabel
()
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/WriterTuple.java:17
↓ 5 callersMethodgetLabel
()
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/GdbElement.java:33
↓ 5 callersMethodgetLine
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/LineAndError.java:14
↓ 5 callersMethodgetLoadProps
()
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/Keys.java:122
↓ 5 callersMethodgetLongFromOperatingSystem
(OperatingSystemMXBean operatingSystem, String methodName)
common/src/main/java/com/alibaba/datax/common/statistics/VMInfo.java:197
↓ 5 callersMethodgetObjName
()
ossreader/src/main/java/com/alibaba/datax/plugin/reader/ossreader/util/OssSplitUtil.java:478
↓ 5 callersMethodgetPassword
()
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/Keys.java:79
↓ 5 callersMethodgetPassword
()
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/Keys.java:82
← previousnext →301–400 of 5,539, ranked by callers