MCPcopy Create free account

hub / github.com/alibaba/DataX / types & classes

Types & classes1,122 in github.com/alibaba/DataX

↓ 1 callersClassConsoleConfig
otsstreamreader/tools/tablestore_streamreader_console.py:11
EnumACTION
common/src/main/java/com/alibaba/datax/common/statistics/PerfRecord.java:68
ClassAbstractCollector
core/src/main/java/com/alibaba/datax/core/statistics/container/collector/AbstractCollector.java:12
ClassAbstractConnHolder
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/ext/AbstractConnHolder.java:11
ClassAbstractContainer
执行容器的抽象类,持有该容器全局的配置 configuration
core/src/main/java/com/alibaba/datax/core/AbstractContainer.java:10
ClassAbstractContainerCommunicator
core/src/main/java/com/alibaba/datax/core/statistics/container/communicator/AbstractContainerCommunicator.java:15
ClassAbstractGdbGraph
@author : Liu Jianping @date : 2019/9/6
gdbreader/src/main/java/com/alibaba/datax/plugin/reader/gdbreader/model/AbstractGdbGraph.java:30
ClassAbstractGdbGraph
@author jerrywang
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/AbstractGdbGraph.java:29
ClassAbstractHbaseTask
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/task/AbstractHbaseTask.java:16
ClassAbstractInsertTask
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/AbstractInsertTask.java:16
ClassAbstractJobPlugin
Created by jingxing on 14-8-24.
common/src/main/java/com/alibaba/datax/common/plugin/AbstractJobPlugin.java:6
ClassAbstractPlugin
common/src/main/java/com/alibaba/datax/common/plugin/AbstractPlugin.java:8
ClassAbstractReporter
core/src/main/java/com/alibaba/datax/core/statistics/container/report/AbstractReporter.java:5
ClassAbstractRestrictedConnection
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedConnection.java:21
ClassAbstractRestrictedPreparedStatement
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:39
ClassAbstractRunner
core/src/main/java/com/alibaba/datax/core/taskgroup/runner/AbstractRunner.java:11
ClassAbstractScanReader
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/task/AbstractScanReader.java:20
ClassAbstractScheduler
core/src/main/java/com/alibaba/datax/core/job/scheduler/AbstractScheduler.java:18
ClassAbstractTGContainerCommunicator
该类是用于处理 taskGroupContainer 的 communication 的收集汇报的父类 主要是 taskCommunicationMap 记录了 taskExecutor 的 communication 属性
core/src/main/java/com/alibaba/datax/core/statistics/container/communicator/taskgroup/AbstractTGContainerCommunicator.java:18
ClassAbstractTaskPlugin
Created by jingxing on 14-8-24.
common/src/main/java/com/alibaba/datax/common/plugin/AbstractTaskPlugin.java:6
ClassAbstractTaskPluginCollector
Created by jingxing on 14-9-11.
core/src/main/java/com/alibaba/datax/core/statistics/plugin/task/AbstractTaskPluginCollector.java:18
EnumActionType
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/Key.java:19
ClassAdb4pgClientProxy
@author yuncheng
adbpgwriter/src/main/java/com/alibaba/datax/plugin/writer/adbpgwriter/copy/Adb4pgClientProxy.java:28
ClassAdb4pgUtil
@author yuncheng
adbpgwriter/src/main/java/com/alibaba/datax/plugin/writer/adbpgwriter/util/Adb4pgUtil.java:28
ClassAdbMysqlWriter
adbmysqlwriter/src/main/java/com/alibaba/datax/plugin/writer/adbmysqlwriter/AdbMysqlWriter.java:16
InterfaceAdbProxy
@author yuncheng
adbpgwriter/src/main/java/com/alibaba/datax/plugin/writer/adbpgwriter/copy/AdbProxy.java:9
ClassAdbpgWriter
@author yuncheng
adbpgwriter/src/main/java/com/alibaba/datax/plugin/writer/adbpgwriter/AdbpgWriter.java:26
ClassAdsClientProxy
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/insert/AdsClientProxy.java:31
ClassAdsException
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/AdsException.java:3
ClassAdsHelper
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/load/AdsHelper.java:27
ClassAdsInsertProxy
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/insert/AdsInsertProxy.java:37
ClassAdsInsertUtil
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/insert/AdsInsertUtil.java:28
InterfaceAdsProxy
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/insert/AdsProxy.java:7
ClassAdsUtil
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/util/AdsUtil.java:21
ClassAdsWriter
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/AdsWriter.java:41
EnumAdsWriterErrorCode
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/AdsWriterErrorCode.java:5
ClassAsyncRetry
common/src/main/java/com/alibaba/datax/common/util/RetryUtil.java:168
ClassBaseObject
common/src/main/java/com/alibaba/datax/common/base/BaseObject.java:8
ClassBaseResponse
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/BaseResponse.java:5
ClassBaseWriter
hologresjdbcwriter/src/main/java/com/alibaba/datax/plugin/writer/hologresjdbcwriter/BaseWriter.java:40
ClassBatchWriteRowCallable
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/callable/BatchWriteRowCallable.java:9
ClassBinaryFileReaderUtil
@Author: guxuan @Date 2022-05-17 15:59
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/reader/binaryFileUtil/BinaryFileReaderUtil.java:24
EnumBinaryFileWriterErrorCode
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/writer/binaryFileUtil/BinaryFileWriterErrorCode.java:5
ClassBinaryFileWriterUtil
@Author: guxuan @Date 2022-05-17 17:01
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/writer/binaryFileUtil/BinaryFileWriterUtil.java:30
ClassBoolColumn
Created by jingxing on 14-8-24.
common/src/main/java/com/alibaba/datax/common/element/BoolColumn.java:13
ClassBufferedRecordExchanger
core/src/main/java/com/alibaba/datax/core/transport/exchanger/BufferedRecordExchanger.java:20
ClassBufferedRecordTransformerExchanger
core/src/main/java/com/alibaba/datax/core/transport/exchanger/BufferedRecordTransformerExchanger.java:22
ClassBuilder
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/HbaseColumnCell.java:94
ClassBuilder
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/config/Option.java:6
ClassBuilder
hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/HbaseColumnCell.java:92
ClassBuilder
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/jest/PutMapping7.java:24
ClassBuilder
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/jest/ClusterInfo.java:23
ClassBuilder
hbase094xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase094xreader/HbaseColumnCell.java:92
ClassBuilder
This builder used to build a new {@link DirectPathConnection }
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/DirectPathConnection.java:235
ClassByteUtils
@Author: guxuan @Date 2022-05-17 16:00
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/reader/binaryFileUtil/ByteUtils.java:9
ClassBytesCast
common/src/main/java/com/alibaba/datax/common/element/ColumnCast.java:197
ClassBytesColumn
Created by jingxing on 14-8-24.
common/src/main/java/com/alibaba/datax/common/element/BytesColumn.java:14
ClassCalculateHelper
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/CalculateHelper.java:14
ClassCassandraReader
cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReader.java:19
EnumCassandraReaderErrorCode
cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderErrorCode.java:5
ClassCassandraReaderHelper
Created by mazhenlin on 2019/8/21.
cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderHelper.java:49
ClassCassandraWriter
Created by mazhenlin on 2019/8/19.
cassandrawriter/src/main/java/com/alibaba/datax/plugin/writer/cassandrawriter/CassandraWriter.java:37
EnumCassandraWriterErrorCode
Created by mazhenlin on 2019/8/19.
cassandrawriter/src/main/java/com/alibaba/datax/plugin/writer/cassandrawriter/CassandraWriterErrorCode.java:8
ClassCassandraWriterHelper
Created by mazhenlin on 2019/8/21.
cassandrawriter/src/main/java/com/alibaba/datax/plugin/writer/cassandrawriter/CassandraWriterHelper.java:43
ClassChannel
Created by jingxing on 14-8-25. <p/> 统计和限速都在这里
core/src/main/java/com/alibaba/datax/core/transport/channel/Channel.java:20
ClassCheckpointTimeTracker
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/core/CheckpointTimeTracker.java:16
ClassClassLoaderSwapper
Created by jingxing on 14-8-29. 为避免jar冲突,比如hbase可能有多个版本的读写依赖jar包,JobContainer和TaskGroupContainer 就需要脱离当前classLoader去加载这些jar包,执行完成后,又退回到原来classLoader上
core/src/main/java/com/alibaba/datax/core/util/container/ClassLoaderSwapper.java:9
ClassClassSize
Created by liqiang on 15/12/12.
core/src/main/java/com/alibaba/datax/core/util/ClassSize.java:6
ClassClassUtil
core/src/main/java/com/alibaba/datax/core/util/ClassUtil.java:5
ClassCliQuery
opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/conn/CliQuery.java:33
ClassClickhouseReader
clickhousereader/src/main/java/com/alibaba/datax/plugin/reader/clickhousereader/ClickhouseReader.java:24
ClassClickhouseWriter
clickhousewriter/src/main/java/com/alibaba/datax/plugin/writer/clickhousewriter/ClickhouseWriter.java:25
EnumClickhouseWriterErrorCode
clickhousewriter/src/main/java/com/alibaba/datax/plugin/writer/clickhousewriter/ClickhouseWriterErrorCode.java:5
ClassClusterInfo
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/jest/ClusterInfo.java:7
ClassClusterInfoResult
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/jest/ClusterInfoResult.java:9
ClassCollectionSplitUtil
Created by jianying.wcj on 2015/3/19 0019. Modified by mingyan.zc on 2016/6/13. Modified by mingyan.zc on 2017/7/5.
mongodbreader/src/main/java/com/alibaba/datax/plugin/reader/mongodbreader/util/CollectionSplitUtil.java:24
ClassCollectorUtil
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/CollectorUtil.java:9
ClassColumn
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/Constant.java:41
ClassColumn
Created by jingxing on 14-8-24. <p/>
common/src/main/java/com/alibaba/datax/common/element/Column.java:13
ClassColumnAdaptor
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/adaptor/ColumnAdaptor.java:9
ClassColumnCast
common/src/main/java/com/alibaba/datax/common/element/ColumnCast.java:13
ClassColumnConversion
备注:datax提供的转换机制有如下限制,如下规则是不能转换的 1. bool -> binary 2. binary -> long, double, bool 3. double -> bool, binary 4. long -> binary
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/ColumnConversion.java:20
ClassColumnConversionOld
备注:datax提供的转换机制有如下限制,如下规则是不能转换的 1. bool -> binary 2. binary -> long, double, bool 3. double -> bool, binary 4. long -> binary
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/ColumnConversionOld.java:19
ClassColumnDataType
ADS column data type. @since 0.0.1
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/ads/ColumnDataType.java:17
ClassColumnEntry
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/reader/ColumnEntry.java:10
ClassColumnInfo
ADS column meta.<br> <p> select ordinal_position,column_name,data_type,type_name,column_comment <br> from information_schema.columns <br> where table_
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/ads/ColumnInfo.java:15
ClassColumnMappingRule
gdbreader/src/main/java/com/alibaba/datax/plugin/reader/gdbreader/mapping/MappingRule.java:71
ClassColumnMeta
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/ColumnMeta.java:3
ClassColumnMetaCache
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/ColumnMetaCache.java:14
EnumColumnType
只对 normal 模式读取时有用,多版本读取时,不存在列类型的
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/enums/ColumnType.java:11
EnumColumnType
只对 normal 模式读取时有用,多版本读取时,不存在列类型的
obhbasewriter/src/main/java/com/alibaba/datax/plugin/writer/obhbasewriter/ColumnType.java:14
EnumColumnType
odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/ColumnType.java:3
EnumColumnType
只对 normal 模式读取时有用,多版本读取时,不存在列类型的
hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/ColumnType.java:11
EnumColumnType
只对 normal 模式读取时有用,多版本读取时,不存在列类型的
hbase094xwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase094xwriter/ColumnType.java:11
EnumColumnType
只对 normal 模式读取时有用,多版本读取时,不存在列类型的
hbase094xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase094xreader/ColumnType.java:11
EnumColumnType
gdbreader/src/main/java/com/alibaba/datax/plugin/reader/gdbreader/Key.java:35
EnumColumnType
只对 normal 模式读取时有用,多版本读取时,不存在列类型的
hbase11xwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xwriter/ColumnType.java:11
EnumColumnType
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/Key.java:103
EnumColumnType
@author daizihao @create 2020-08-31 19:12
kuduwriter/src/main/java/com/q1/datax/plugin/writer/kudu11xwriter/ColumnType.java:11
ClassColumnTypeUtil
@Author: guxuan @Date 2022-05-17 16:40
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/util/ColumnTypeUtil.java:16
next →1–100 of 1,122, ranked by callers