MCPcopy Create free account

hub / github.com/alibaba/DataX / functions

Functions5,539 in github.com/alibaba/DataX

⨍ Functions 5,539◇ Types & classes 1,122
↓ 3 callersMethodcloseAdmin
(Admin admin)
hbase11xwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xwriter/Hbase11xHelper.java:157
↓ 3 callersMethodcloseBufferedMutator
(BufferedMutator bufferedMutator)
hbase11xwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xwriter/Hbase11xHelper.java:166
↓ 3 callersMethodcloseConnection
(Connection hConnection)
hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/Hbase11xHelper.java:103
↓ 3 callersMethodcollectDirtyRecord
(Record dirtyRecord, Throwable t, String errorMessage)
core/src/main/java/com/alibaba/datax/core/statistics/plugin/task/HttpPluginCollector.java:17
↓ 3 callersMethodcomparePrimaryKeyColumnList
比较PrimaryKeyColumn List的大小 返回 -1 表示before小于after 0 表示before等于after 1 表示before大于after @param before @param after @return
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/CompareHelper.java:20
↓ 3 callersMethodcompareTo
(ObVersion o)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/util/ObVersion.java:57
↓ 3 callersMethodconfToJson
(OTSConf conf)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/GsonParser.java:37
↓ 3 callersMethodconvertBytesToAssignType
(ColumnType columnType, byte[] byteArray)
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/task/ScanMultiVersionReader.java:67
↓ 3 callersMethodcreate
(Configuration config, ExportType exportType)
gdbreader/src/main/java/com/alibaba/datax/plugin/reader/gdbreader/mapping/MappingRuleFactory.java:32
↓ 3 callersMethodcreateConnection
Create a new {@link DirectPathConnection } @param host @param port @param user @param tenant @param password @param schema @param table @param parall
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/DirectPathConnection.java:358
↓ 3 callersMethodcreateMasterTunnelUpload
(final TableTunnel tunnel, final String projectName, final S
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/util/OdpsUtil.java:215
↓ 3 callersMethodcreateSupTable
(String precision)
tdenginewriter/src/test/java/com/alibaba/datax/plugin/writer/tdenginewriter/Stream2TDengineTest.java:49
↓ 3 callersMethodcreateSupTable
(String precision)
tdenginereader/src/test/java/com/alibaba/datax/plugin/reader/TDengine2DMTest.java:53
↓ 3 callersMethoddestroy
()
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/Neo4jClient.java:136
↓ 3 callersMethoddoBigIntegerSplit
(BigInteger left, BigInteger right, int expectSliceNumber)
common/src/main/java/com/alibaba/datax/common/util/RangeSplitUtil.java:43
↓ 3 callersMethoddoLongSplit
(long left, long right, int expectSliceNumber)
common/src/main/java/com/alibaba/datax/common/util/RangeSplitUtil.java:33
↓ 3 callersMethoddoOneInsert
(Connection connection, List<Record> buffer)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/CommonRdbmsWriter.java:379
↓ 3 callersMethoddoRead
(RecordSender recordSender, TaskPluginCollector taskPluginCollector, TaskContext context)
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/ext/ReaderTask.java:228
↓ 3 callersMethoddoRetry
(Callable<T> callable, int retryTimes, long sleepTimeInMilliSecond, boolean exponential, List<Class<?>> retryE
common/src/main/java/com/alibaba/datax/common/util/RetryUtil.java:96
↓ 3 callersMethoddoStat
()
core/src/main/java/com/alibaba/datax/core/transport/exchanger/TransformerExchanger.java:129
↓ 3 callersMethoddump4RDB
(TSDBConnection conn, String metric, Map<String, String> tags, Long start, Long end,
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/TSDBDump.java:64
↓ 3 callersMethodensureStringExists
(Configuration jobConfig,String keyword)
cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderHelper.java:576
↓ 3 callersMethodescapeDatabaseKeyword
(String keyword)
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/ObReaderUtils.java:57
↓ 3 callersMethodescapeDatabaseKeyword
(String keyword)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/util/ObWriterUtils.java:37
↓ 3 callersMethodexecuteUpdate
(Connection conn, String sql)
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java:279
↓ 3 callersMethodexpand
(List<Object> list, int size)
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:1008
↓ 3 callersMethodextractFromConfiguration
(final Object object)
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:817
↓ 3 callersMethodflush
(String label, boolean waitUtilDone)
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisWriterManager.java:87
↓ 3 callersMethodflush
(String label, boolean waitUtilDone)
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/SelectdbWriterManager.java:89
↓ 3 callersMethodflush
(String label, boolean waitUtilDone)
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksWriterManager.java:92
↓ 3 callersMethodformatPartition
(String partitionString, Boolean printLog)
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/util/OdpsUtil.java:67
↓ 3 callersMethodfromJson
(String jsonStr)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/utils/GsonParser.java:34
↓ 3 callersMethodgenerateDmlSql
(Connection connection, Record record, String mode)
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/insert/AdsInsertProxy.java:412
↓ 3 callersMethodgenerateJdbcUrl
(Configuration configuration)
adbpgwriter/src/main/java/com/alibaba/datax/plugin/writer/adbpgwriter/util/Adb4pgUtil.java:97
↓ 3 callersMethodgeneratePluginKey
(PluginType pluginType, String pluginName)
core/src/main/java/com/alibaba/datax/core/util/container/LoadUtil.java:63
↓ 3 callersMethodgetAccessId
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:99
↓ 3 callersMethodgetAccessKey
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:107
↓ 3 callersMethodgetAdbpgConnect
(Configuration conf)
adbpgwriter/src/main/java/com/alibaba/datax/plugin/writer/adbpgwriter/util/Adb4pgUtil.java:89
↓ 3 callersMethodgetAllPartColumns
(TableSchema schema)
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/util/OdpsUtil.java:554
↓ 3 callersMethodgetAttemptCount
()
core/src/main/java/com/alibaba/datax/core/taskgroup/TaskGroupContainer.java:544
↓ 3 callersMethodgetByTypeName
(String modeName)
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/enums/ModeType.java:20
↓ 3 callersMethodgetCf
()
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/HbaseColumnCell.java:73
↓ 3 callersMethodgetColumnIndex
(List<String> columnsInIndex, List<String> allColumns)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/util/ObWriterUtils.java:157
↓ 3 callersMethodgetColumnMetaData
@return Left:ColumnName Middle:ColumnType Right:ColumnTypeName
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DBUtil.java:538
↓ 3 callersMethodgetColumnName
()
hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/HbaseColumnCell.java:67
↓ 3 callersMethodgetColumnType
()
odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/InternalColumnInfo.java:17
↓ 3 callersMethodgetColumns
()
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/Keys.java:99
↓ 3 callersMethodgetConnection
(final String url)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/ext/OBDataSourceV10.java:96
↓ 3 callersMethodgetCount
()
common/src/main/java/com/alibaba/datax/common/statistics/PerfRecord.java:212
↓ 3 callersMethodgetDataCacheSize
()
milvuswriter/src/main/java/com/alibaba/datax/plugin/writer/milvuswriter/MilvusBufferWriter.java:73
↓ 3 callersMethodgetDataSize
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSLine.java:74
↓ 3 callersMethodgetDatabase
()
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/StarRocksWriterOptions.java:90
↓ 3 callersMethodgetDatahubClient
(Configuration jobConfig)
datahubreader/src/main/java/com/alibaba/datax/plugin/reader/datahubreader/DatahubClientHelper.java:15
↓ 3 callersMethodgetDateformat
()
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/HbaseColumnCell.java:81
↓ 3 callersMethodgetDelaySendMillinSeconds
(int hadRetryTimes, int initSleepInMilliSecond)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/Common.java:121
↓ 3 callersMethodgetDelta
()
common/src/main/java/com/alibaba/datax/common/statistics/VMInfo.java:129
↓ 3 callersMethodgetDeltaString
()
common/src/main/java/com/alibaba/datax/common/statistics/VMInfo.java:280
↓ 3 callersMethodgetDirection
(List<PrimaryKeyColumn> begin, List<PrimaryKeyColumn> end)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/Common.java:45
↓ 3 callersMethodgetDps4RDB
(String metric, String dps)
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/TSDBDump.java:324
↓ 3 callersMethodgetEnableSeekIteratorByTimestamp
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/config/OTSStreamReaderConfig.java:155
↓ 3 callersMethodgetEncodePkColumnMapping
(TableMeta meta, List<PrimaryKeySchema> attrColumns)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/Common.java:159
↓ 3 callersMethodgetFieldDelimiter
(Configuration conf)
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/Key.java:180
↓ 3 callersMethodgetFileFormatByConfiguration
获取文件类型: 目前支持text,csv,excel,binary @param configuration @return
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/FileFormat.java:38
↓ 3 callersMethodgetHbaseConnection
(String hbaseConfig)
hbase11xwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xwriter/Hbase11xHelper.java:43
↓ 3 callersMethodgetHostAddress
()
common/src/main/java/com/alibaba/datax/common/statistics/PerfTrace.java:759
↓ 3 callersMethodgetIndexName
find out the indexes which contains all columns in where conditions @param conn @param table @param colNamesInCondition @return
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/ObReaderUtils.java:589
↓ 3 callersMethodgetInitiateMultipartUploadRequest
(String currentObject)
osswriter/src/main/java/com/alibaba/datax/plugin/writer/osswriter/OssWriterProxy.java:40
↓ 3 callersMethodgetInputStream
(String filepath)
hdfsreader/src/main/java/com/alibaba/datax/plugin/reader/hdfsreader/DFSUtil.java:238
↓ 3 callersMethodgetJdbcConnection
获取JDBC连接，轻量级连接，使用完后必须显式close
hbase11xsqlwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xsqlwriter/HbaseSQLHelper.java:106
↓ 3 callersMethodgetJdbcUrl
()
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/Keys.java:63
↓ 3 callersMethodgetJdbcUrl
()
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/Keys.java:66
↓ 3 callersMethodgetJdbcUrl
()
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/StarRocksWriterOptions.java:86
↓ 3 callersMethodgetJsonObject
(List<String> paths, JSONObject data)
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/JsonPathUtil.java:9
↓ 3 callersMethodgetKey
()
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/GdbElement.java:101
↓ 3 callersMethodgetLastBlockBuffer
()
osswriter/src/main/java/com/alibaba/datax/plugin/writer/osswriter/OssSingleObject.java:74
↓ 3 callersMethodgetMaxIdLength
()
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/mapping/MapperConfig.java:52
↓ 3 callersMethodgetMeasurementName
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:189
↓ 3 callersMethodgetMessage
()
core/src/main/java/com/alibaba/datax/core/statistics/communication/Communication.java:107
↓ 3 callersMethodgetMessage
(Object obj)
common/src/main/java/com/alibaba/datax/common/exception/DataXException.java:55
↓ 3 callersMethodgetMeta
()
common/src/main/java/com/alibaba/datax/common/element/Record.java:27
↓ 3 callersMethodgetMetric
()
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/DataPoint4TSDB.java:40
↓ 3 callersMethodgetName
()
milvuswriter/src/main/java/com/alibaba/datax/plugin/writer/milvuswriter/MilvusColumn.java:24
↓ 3 callersMethodgetOTSInstance
(OTSConf conf)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/Common.java:138
↓ 3 callersMethodgetOTSInstance
(OTSConf conf)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/OtsHelper.java:27
↓ 3 callersMethodgetOTSRequestForGet
(PrimaryKey primaryKey)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/core/CheckpointTimeTracker.java:210
↓ 3 callersMethodgetPlugin
()
core/src/main/java/com/alibaba/datax/core/taskgroup/runner/AbstractRunner.java:36
↓ 3 callersMethodgetPrimaryKeyForShardTimeCheckpoint
(String shardId, long timestamp)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/core/CheckpointTimeTracker.java:188
↓ 3 callersMethodgetQualifier
()
hbase094xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase094xreader/HbaseColumnCell.java:75
↓ 3 callersMethodgetRange
(SyncClientInterface ots, RangeRowQueryCriteria rangeRowQueryCriteria, int retry, int sleepInMillisecond)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/OtsHelper.java:59
↓ 3 callersMethodgetReaderPluginSplitConf
()
common/src/main/java/com/alibaba/datax/common/plugin/AbstractPlugin.java:92
↓ 3 callersMethodgetRecord
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/WithRecord.java:6
↓ 3 callersMethodgetRecordReader
odpsreader采用的直接读取所有列的downloadSession
odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/util/OdpsUtil.java:366
↓ 3 callersMethodgetRowChange
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSLine.java:78
↓ 3 callersMethodgetRows
()
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksFlushTuple.java:20
↓ 3 callersMethodgetSize
()
common/src/main/java/com/alibaba/datax/common/statistics/PerfRecord.java:216
↓ 3 callersMethodgetSkipCount
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/model/ShardCheckpoint.java:45
↓ 3 callersMethodgetState
()
core/src/main/java/com/alibaba/datax/core/taskgroup/runner/TaskGroupContainerRunner.java:37
↓ 3 callersMethodgetStreamResponse
(SyncClientInterface ots, String tableName, boolean isTimeseriesTable)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/utils/OTSHelper.java:46
↓ 3 callersMethodgetTable
(Odps odps, String projectName, String tableName)
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/util/OdpsUtil.java:110
↓ 3 callersMethodgetTableColumnsByConn
(DataBaseType dataBaseType, Connection conn, String tableName, String basicMsg)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DBUtil.java:511
← previousnext →601–700 of 5,539, ranked by callers