Code
Hub
Workspaces
Following
Trending
Connect
MCP
copy
Create free account
hub
/
github.com/alibaba/DataX
/ functions
Functions
5,539 in github.com/alibaba/DataX
⨍
Functions
5,539
◇
Types & classes
1,122
↓ 3 callers
Method
getTableMeta
(SyncClientInterface ots, String tableName)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/OtsWriterMasterProxy.java:119
↓ 3 callers
Method
getTableName
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/model/StreamJob.java:41
↓ 3 callers
Method
getTagString
(List<ColumnMeta> columnMetas, Record record)
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java:224
↓ 3 callers
Method
getTaskId
()
core/src/main/java/com/alibaba/datax/core/taskgroup/TaskGroupContainer.java:536
↓ 3 callers
Method
getTimeInHour
Get the hour. @param ms time in millisecond
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/util/TimeUtils.java:35
↓ 3 callers
Method
getTimeInHour
Get the hour. @param ms time in millisecond
opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/util/TimeUtils.java:51
↓ 3 callers
Method
getTimestamp
()
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/DataPoint4TSDB.java:32
↓ 3 callers
Method
getTotalBytes
(final Communication communication)
core/src/main/java/com/alibaba/datax/core/statistics/communication/CommunicationTool.java:221
↓ 3 callers
Method
getTransferColumnNumber
()
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/TaskContext.java:144
↓ 3 callers
Method
getWhere
()
hbase11xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xsqlreader/HbaseSQLReaderConfig.java:177
↓ 3 callers
Method
getZkUrl
()
hbase11xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xsqlreader/HbaseSQLReaderConfig.java:21
↓ 3 callers
Method
indicesExists
(String indexName)
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/ElasticSearchClient.java:86
↓ 3 callers
Method
init
()
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/Neo4jClient.java:52
↓ 3 callers
Method
initOdpsProject
(Configuration originalConfig)
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/util/OdpsUtil.java:81
↓ 3 callers
Method
initOssClient
(Configuration conf)
ossreader/src/main/java/com/alibaba/datax/plugin/reader/ossreader/util/OssUtil.java:20
↓ 3 callers
Method
insert
Inserts data into the direct load operation. @param bucket The data bucket containing rows to insert. @throws SQLException if an error occurs during
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/ObTableDirectLoad.java:137
↓ 3 callers
Method
instantiate
通过反射构造类对象 @param className 反射的类名称 @param t 反射类的类型Class对象 @param args 构造参数
core/src/main/java/com/alibaba/datax/core/util/ClassUtil.java:18
↓ 3 callers
Method
invokeAll
()
core/src/main/java/com/alibaba/datax/core/container/util/HookInvoker.java:42
↓ 3 callers
Method
isBinary
()
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/FileFormat.java:85
↓ 3 callers
Method
isDirExist
(String directoryPath)
ftpreader/src/main/java/com/alibaba/datax/plugin/reader/ftpreader/SftpHelper.java:97
↓ 3 callers
Method
isDone
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSTimeseriesRowTask.java:47
↓ 3 callers
Method
isLongType
(int type)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/util/SingleTableSplitUtil.java:256
↓ 3 callers
Method
isNewVersion
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:163
↓ 3 callers
Method
isPartitionTable
()
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/PartInfo.java:32
↓ 3 callers
Method
isPartitionedTable
(Table table)
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/util/OdpsUtil.java:140
↓ 3 callers
Method
isPathList
(final String path)
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:1016
↓ 3 callers
Method
isPathMap
(final String path)
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:1020
↓ 3 callers
Method
isPeer2PeerCopyMode
()
osswriter/src/main/java/com/alibaba/datax/plugin/writer/osswriter/OssWriter.java:572
↓ 3 callers
Method
isPeer2PeerCopyMode
()
osswriter/src/main/java/com/alibaba/datax/plugin/writer/osswriter/OssWriter.java:1169
↓ 3 callers
Method
isShutdown
()
core/src/main/java/com/alibaba/datax/core/taskgroup/TaskGroupContainer.java:563
↓ 3 callers
Method
isStringType
(int type)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/util/SingleTableSplitUtil.java:271
↓ 3 callers
Method
jsonToMeta
(String jsonStr)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/GsonParser.java:52
↓ 3 callers
Method
listShard
获取通道的分片信息
loghubwriter/src/main/java/com/alibaba/datax/plugin/writer/loghubwriter/LogHubWriter.java:122
↓ 3 callers
Method
loadAdsData
(AdsHelper helper, String odpsTableName, String odpsPartition)
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/AdsWriter.java:264
↓ 3 callers
Method
loadDatabasePrecision
()
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/SchemaManager.java:25
↓ 3 callers
Method
mark
(State state)
core/src/main/java/com/alibaba/datax/core/taskgroup/runner/AbstractRunner.java:57
↓ 3 callers
Method
mkdir
warn: 不支持递归创建, 比如 mkdir -p
ftpwriter/src/main/java/com/alibaba/datax/plugin/writer/ftpwriter/util/IFtpHelper.java:16
↓ 3 callers
Method
open
()
core/src/main/java/com/alibaba/datax/core/transport/channel/Channel.java:91
↓ 3 callers
Method
pKColumnList2RowPrimaryKey
将 {@link com.alicloud.openservices.tablestore.model.PrimaryKeyColumn}的列表转为{@link com.aliyun.openservices.ots.model.RowPrimaryKey} @param list @return
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/OtsReaderSlaveProxyOld.java:151
↓ 3 callers
Method
parse
指定Job配置路径，ConfigParser会解析Job、Plugin、Core全部信息，并以Configuration返回 不同于Core的ConfigParser,这里的core,plugin 不依赖于编译后的datax.home,而是扫描程序编译后的target目录
datax-example/datax-example-core/src/main/java/com/alibaba/datax/example/util/ExampleConfigParser.java:27
↓ 3 callers
Method
parseColumnType
(String type)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/WriterModelParser.java:114
↓ 3 callers
Method
parseMap
(JSONObject json, MapTypeInfo typeInfo)
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/OdpsWriterProxy.java:615
↓ 3 callers
Method
parsePrimaryKeyColumnArray
(Object arrayObj)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/ParamParser.java:81
↓ 3 callers
Method
parseStruct
(JSONObject json, StructTypeInfo struct)
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/OdpsWriterProxy.java:944
↓ 3 callers
Method
port
(int port)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/DirectLoaderBuilder.java:70
↓ 3 callers
Method
preCheck
()
core/src/main/java/com/alibaba/datax/core/job/JobContainer.java:184
↓ 3 callers
Method
pushTerminate
(final TerminateRecord r)
core/src/main/java/com/alibaba/datax/core/transport/channel/Channel.java:126
↓ 3 callers
Method
queryRange4SingleField
(TSDBConnection conn, String metric, Map<String, String> tags,
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/TSDBDump.java:202
↓ 3 callers
Method
readFields
(Group g, org.apache.parquet.schema.Type type, int index, Map<String, ParquetMeta> parquetMetaMap, boolean isU
hdfsreader/src/main/java/com/alibaba/datax/plugin/reader/hdfsreader/DFSUtil.java:965
↓ 3 callers
Method
run
()
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisWriterManager.java:131
↓ 3 callers
Method
runInternal
(String dsl, Map<String, Object> params)
gdbreader/src/main/java/com/alibaba/datax/plugin/reader/gdbreader/model/AbstractGdbGraph.java:60
↓ 3 callers
Method
sendDPs
Send data points by metric & start time & end time. @param metric metric @param start startTime @param end endTime @param recor
opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/conn/Connection4TSDB.java:69
↓ 3 callers
Method
sendRecords
Send data points for RDB with single field.
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/Connection4TSDB.java:73
↓ 3 callers
Method
setArray
(boolean array)
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/ElasticSearchColumn.java:103
↓ 3 callers
Method
setByte
(int parameterIndex, byte x)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:58
↓ 3 callers
Method
setByteSize
(int byteSize)
common/src/main/java/com/alibaba/datax/common/element/Column.java:47
↓ 3 callers
Method
setBytes
(int parameterIndex, byte[] x)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:98
↓ 3 callers
Method
setColumnName
(String columnName)
odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/InternalColumnInfo.java:13
↓ 3 callers
Method
setColumns
(List<ColumnInfo> columns)
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/ads/TableInfo.java:75
↓ 3 callers
Method
setConn
(Connection conn)
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/TaskContext.java:62
↓ 3 callers
Method
setContainerCommunicator
(AbstractContainerCommunicator containerCommunicator)
core/src/main/java/com/alibaba/datax/core/AbstractContainer.java:29
↓ 3 callers
Method
setEndTimestampMillis
(long endTimestampMillis)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/config/OTSStreamReaderConfig.java:135
↓ 3 callers
Method
setMetric
(String metric)
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/DataPoint4TSDB.java:44
↓ 3 callers
Method
setNanos
(int nanos)
common/src/main/java/com/alibaba/datax/common/element/DateColumn.java:46
↓ 3 callers
Method
setOperation
(OTSOpType operation)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:53
↓ 3 callers
Method
setPartitionName
(String partitionName)
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/TaskContext.java:27
↓ 3 callers
Method
setQuerySql
(String querySql)
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/TaskContext.java:92
↓ 3 callers
Method
setQueryTimeout
(int seconds)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:549
↓ 3 callers
Method
setRawData
(Object rawData)
common/src/main/java/com/alibaba/datax/common/element/Column.java:43
↓ 3 callers
Method
setShardTimeCheckpoint
设置某个分片某个时间的checkpoint, 用于寻找某个分片在一定区间内较大的checkpoint, 减少扫描的数据量. @param shardId @param timestamp @param checkpointValue
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/core/CheckpointTimeTracker.java:98
↓ 3 callers
Method
setShort
(int parameterIndex, short x)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:63
↓ 3 callers
Method
setSize
(RowChange change)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSLine.java:52
↓ 3 callers
Method
setStartTimestampMillis
(long startTimestampMillis)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/config/OTSStreamReaderConfig.java:127
↓ 3 callers
Method
setSubType
(DateType subType)
common/src/main/java/com/alibaba/datax/common/element/DateColumn.java:169
↓ 3 callers
Method
setTableName
(String tableName)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:102
↓ 3 callers
Method
setTableName
(String tableName)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:127
↓ 3 callers
Method
setTags
(Map<String, Object> tags)
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/DataPoint4TSDB.java:52
↓ 3 callers
Method
setTaskGroupId
@param taskGroupId the taskGroupId to set
core/src/main/java/com/alibaba/datax/core/taskgroup/runner/AbstractRunner.java:83
↓ 3 callers
Method
setTaskId
(int taskId)
core/src/main/java/com/alibaba/datax/core/taskgroup/runner/AbstractRunner.java:99
↓ 3 callers
Method
setTimestamp
(long timestamp)
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/DataPoint4TSDB.java:36
↓ 3 callers
Method
setUrl
(String url)
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/HttpPutBuilder.java:21
↓ 3 callers
Method
sleepMillis
(long timeToSleepMillis)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/utils/TimeUtils.java:26
↓ 3 callers
Method
split
(int adviceNumber)
tdenginereader/src/main/java/com/alibaba/datax/plugin/reader/TDengineReader.java:105
↓ 3 callers
Method
split
(HbaseSQLReaderConfig readerConfig)
hbase11xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xsqlreader/HbaseSQLHelper.java:96
↓ 3 callers
Method
start
()
core/src/main/java/com/alibaba/datax/core/taskgroup/TaskGroupContainer.java:92
↓ 3 callers
Method
sumPerf4EndPrint
(List<PerfRecord> totalEndReport)
common/src/main/java/com/alibaba/datax/common/statistics/PerfTrace.java:422
↓ 3 callers
Method
timeout
(long timeout)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/DirectLoaderBuilder.java:120
↓ 3 callers
Method
toJson
(List<StreamShard> allShards)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/utils/GsonParser.java:30
↓ 3 callers
Method
transOdpsMapToJavaMap
(Map odpsMap, MapTypeInfo typeInfo)
odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/ReaderProxy.java:561
↓ 3 callers
Method
transportOneRecord
(RecordSender recordSender, Configuration configuration, TaskPluginCollector taskPluginC
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/reader/UnstructuredStorageReaderUtil.java:312
↓ 3 callers
Method
transportOneRecord
异常表示脏数据
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/writer/UnstructuredStorageWriterUtil.java:296
↓ 3 callers
Method
uploadOnePartForSingleObject
( final byte[] byteArray, final String uploadId, final List<PartETag> part
osswriter/src/main/java/com/alibaba/datax/plugin/writer/osswriter/OssWriterProxy.java:128
↓ 3 callers
Method
validateCsvReaderConfig
(Configuration readerConfiguration)
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/reader/UnstructuredStorageReaderUtil.java:625
↓ 3 callers
Method
validateDoubleNotOverFlow
(final BigDecimal decimal)
common/src/main/java/com/alibaba/datax/common/element/OverFlowUtil.java:53
↓ 3 callers
Method
validateDoubleSpecific
(final String data)
common/src/main/java/com/alibaba/datax/common/element/StringColumn.java:34
↓ 3 callers
Method
validateLongNotOverFlow
(final BigInteger integer)
common/src/main/java/com/alibaba/datax/common/element/OverFlowUtil.java:28
↓ 3 callers
Method
validateParameter
check parameter: writeMode, encoding, compress, filedDelimiter
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/writer/UnstructuredStorageWriterUtil.java:46
↓ 3 callers
Method
version
(String address, String username, String password)
tsdbwriter/src/main/java/com/alibaba/datax/plugin/writer/util/TSDBUtils.java:26
↓ 3 callers
Method
version
Get the version of Database. @return version
opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/conn/Connection4TSDB.java:45
↓ 3 callers
Method
version
(String address)
opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/util/TSDBUtils.java:41
← previous
next →
701–800 of 5,539, ranked by callers