MCPcopy Create free account

hub / github.com/alibaba/DataX / functions

Functions5,539 in github.com/alibaba/DataX

⨍ Functions 5,539◇ Types & classes 1,122
↓ 4 callersMethodgetInstId
()
common/src/main/java/com/alibaba/datax/common/statistics/PerfRecord.java:220
↓ 4 callersMethodgetInstanceName
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:115
↓ 4 callersMethodgetKuduClient
(String kuduConfig)
kuduwriter/src/main/java/com/q1/datax/plugin/writer/kudu11xwriter/Kudu11xHelper.java:52
↓ 4 callersMethodgetListWithJson
(Configuration config, String path, Class<T> clazz)
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/util/CustomPartitionUtils.java:21
↓ 4 callersMethodgetMasterTimeout
(Configuration conf)
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/Key.java:172
↓ 4 callersMethodgetMode
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/config/OTSStreamReaderConfig.java:163
↓ 4 callersMethodgetName
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSPrimaryKeyColumn.java:9
↓ 4 callersMethodgetNamespace
()
hbase11xsqlwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xsqlwriter/HbaseSQLWriterConfig.java:94
↓ 4 callersMethodgetNanos
()
common/src/main/java/com/alibaba/datax/common/element/DateColumn.java:42
↓ 4 callersMethodgetOTSInstance
(OTSStreamReaderConfig config)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/utils/OTSHelper.java:28
↓ 4 callersMethodgetPartitionName
()
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/TaskContext.java:23
↓ 4 callersMethodgetPhase
()
common/src/main/java/com/alibaba/datax/common/statistics/PerfRecord.java:200
↓ 4 callersMethodgetPkIndexs
()
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/TaskContext.java:108
↓ 4 callersMethodgetPluginConf
(PluginType pluginType, String pluginName)
core/src/main/java/com/alibaba/datax/core/util/container/LoadUtil.java:69
↓ 4 callersMethodgetPrimaryKeyForCheckpoint
(long timestamp, String shardId)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/core/CheckpointTimeTracker.java:152
↓ 4 callersMethodgetQualifier
()
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/HbaseColumnCell.java:77
↓ 4 callersMethodgetReportCommunication
(Communication now, Communication old, int totalStage)
core/src/main/java/com/alibaba/datax/core/statistics/communication/CommunicationTool.java:52
↓ 4 callersMethodgetSavePoint
()
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/TaskContext.java:100
↓ 4 callersMethodgetSchema
()
hbase11xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xsqlreader/HbaseSQLReaderConfig.java:185
↓ 4 callersMethodgetSplit
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSRange.java:25
↓ 4 callersMethodgetSrcName
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSAttrColumn.java:39
↓ 4 callersMethodgetStart
()
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/reader/split/StartEndPair.java:29
↓ 4 callersMethodgetStartOffset
()
ossreader/src/main/java/com/alibaba/datax/plugin/reader/ossreader/util/OssSplitUtil.java:457
↓ 4 callersMethodgetStreamLoadFormat
()
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/Keys.java:152
↓ 4 callersMethodgetTable
(com.alibaba.datax.common.util.Configuration configuration)
hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/Hbase11xHelper.java:61
↓ 4 callersMethodgetTable
()
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/ConcurrentTableWriterTask.java:477
↓ 4 callersMethodgetTableName
@return 获取表名
hbase11xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xsqlreader/HbaseSQLReaderConfig.java:51
↓ 4 callersMethodgetTableSchema
获取一张表的元数据信息 @param conn hbsae sql的jdbc连接 @param fullTableName 目标表的完整表名 @return 表的元数据
hbase11xsqlwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xsqlwriter/HbaseSQLHelper.java:158
↓ 4 callersMethodgetTotalErrorRecords
(final Communication communication)
core/src/main/java/com/alibaba/datax/core/statistics/communication/CommunicationTool.java:93
↓ 4 callersMethodgetType
()
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/PrimaryKeyInfo.java:24
↓ 4 callersMethodgetType
()
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/model/PartitionInfo.java:56
↓ 4 callersMethodgetUnixTimeFromDateTime
(String dateTime)
datahubreader/src/main/java/com/alibaba/datax/plugin/reader/datahubreader/DatahubReaderUtils.java:21
↓ 4 callersMethodgetValues
()
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/MultiFieldQueryResult.java:57
↓ 4 callersMethodgetVmInfo
@return null or vmInfo. null is something error, job no care it.
common/src/main/java/com/alibaba/datax/common/statistics/VMInfo.java:28
↓ 4 callersMethodinitialize
初始化JDBC操作对象及列类型 @throws SQLException
hbase20xsqlwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase20xsqlwriter/HBase20xSQLWriterTask.java:66
↓ 4 callersMethodisClosed
Return whether this connection is closed. @return boolean
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/DirectPathConnection.java:183
↓ 4 callersMethodisConstant
()
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/HbaseColumnCell.java:89
↓ 4 callersMethodisEnable
()
common/src/main/java/com/alibaba/datax/common/statistics/PerfTrace.java:282
↓ 4 callersMethodisFinished
()
core/src/main/java/com/alibaba/datax/core/job/meta/State.java:25
↓ 4 callersMethodisNewVersion
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:167
↓ 4 callersMethodisPathexists
(String filePath)
hdfswriter/src/main/java/com/alibaba/datax/plugin/writer/hdfswriter/HdfsHelper.java:159
↓ 4 callersMethodisSecond
Weather the timestamp is second. @param ts timestamp
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/util/TimeUtils.java:26
↓ 4 callersMethodisSecond
Weather the timestamp is second. @param ts timestamp
opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/util/TimeUtils.java:42
↓ 4 callersMethodjsonToConf
(String jsonStr)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/GsonParser.java:23
↓ 4 callersMethodjsonToRange
(String jsonStr)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/GsonParser.java:32
↓ 4 callersMethodload
(Configuration param)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:197
↓ 4 callersMethodloadDriverClass
(String pluginType, String pluginName)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DBUtil.java:791
↓ 4 callersMethodloginFtpServer
(String host, String username, String password, int port, int timeout)
ftpwriter/src/main/java/com/alibaba/datax/plugin/writer/ftpwriter/util/IFtpHelper.java:9
↓ 4 callersMethodlogoutFtpServer
()
ftpwriter/src/main/java/com/alibaba/datax/plugin/writer/ftpwriter/util/IFtpHelper.java:11
↓ 4 callersMethodmakeSureBInA
(List<String> aList, List<String> bList, boolean caseSensitive)
common/src/main/java/com/alibaba/datax/common/util/ListUtil.java:80
↓ 4 callersMethodmakeSureNoValueDuplicate
(List<String> aList, boolean caseSensitive)
common/src/main/java/com/alibaba/datax/common/util/ListUtil.java:33
↓ 4 callersMethodotsColumnToDataxColumn
(com.alicloud.openservices.tablestore.model.Column c)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/TranformHelper.java:18
↓ 4 callersMethodparse
(String sp, String dSp)
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DelimiterParser.java:11
↓ 4 callersMethodparseColumn
用于解析列配置
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/util/ObHbaseReaderUtil.java:213
↓ 4 callersFunctionparse_timestamp
(line)
core/src/main/bin/dxprof.py:18
↓ 4 callersMethodpassword
Get the address of Database. @return host+ip
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/Connection4TSDB.java:37
↓ 4 callersMethodprepareJdbcUrl
(Configuration conf)
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/util/AdsUtil.java:143
↓ 4 callersMethodput
(String address, String database, String username, String password, List<DataPoint4TSDB> dps)
tsdbwriter/src/main/java/com/alibaba/datax/plugin/writer/util/TSDBUtils.java:48
↓ 4 callersMethodputLog
(final PutLogsRequest request)
loghubwriter/src/main/java/com/alibaba/datax/plugin/writer/loghubwriter/LogHubWriter.java:276
↓ 4 callersMethodreadFromStream
(InputStream inputStream, String context, Configuration readerSliceConfig, RecordSender recordSende
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/reader/UnstructuredStorageReaderUtil.java:85
↓ 4 callersMethodreadRecord
(Record record)
hbase11xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xsqlreader/HbaseSQLReaderTask.java:156
↓ 4 callersMethodreconnect
()
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/ext/ConnHolder.java:27
↓ 4 callersMethodrecordToString
(Record record)
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/OpentsdbDataHandler.java:85
↓ 4 callersMethodrenderPreOrPostSqls
(List<String> preOrPostSqls, String tableName)
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisUtil.java:45
↓ 4 callersMethodrenderPreOrPostSqls
(List<String> preOrPostSqls, String tableName)
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/SelectdbUtil.java:45
↓ 4 callersMethodrenderPreOrPostSqls
(List<String> preOrPostSqls, String tableName)
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/util/StarRocksWriterUtil.java:42
↓ 4 callersMethodrenderPreOrPostSqls
(List<String> preOrPostSqls, String tableName)
hologresjdbcwriter/src/main/java/com/alibaba/datax/plugin/writer/hologresjdbcwriter/util/WriterUtil.java:80
↓ 4 callersMethodschedule
(List<Configuration> configurations)
core/src/main/java/com/alibaba/datax/core/job/scheduler/AbstractScheduler.java:36
↓ 4 callersMethodsetFetchSize
(int rows)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:604
↓ 4 callersMethodsetIoThreadCount
(int ioThreadCount)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:126
↓ 4 callersMethodsetName
(String name)
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/model/PartitionInfo.java:68
↓ 4 callersMethodsetPrimaryKey
(Boolean primaryKey)
milvuswriter/src/main/java/com/alibaba/datax/plugin/writer/milvuswriter/MilvusColumn.java:77
↓ 4 callersMethodsetRange
(OTSRange range)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:135
↓ 4 callersMethodsetSocketTimeoutInMillisecond
(int socketTimeoutInMillisecond)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:132
↓ 4 callersMethodsplitAndWrap
(String left, String right, int expectSliceNumber, String columnNa
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/RdbmsRangeSplitWrap.java:12
↓ 4 callersMethodstart
example对外暴露的启动入口 使用前最好看下 datax-example/doc/README.MD @param jobPath 任务json绝对路径
datax-example/datax-example-core/src/main/java/com/alibaba/datax/example/ExampleContainer.java:19
↓ 4 callersMethodstring2Date
(final StringColumn column)
common/src/main/java/com/alibaba/datax/common/element/ColumnCast.java:21
↓ 4 callersMethodtestConnWithoutRetry
(DataBaseType dataBaseType, String url, String user, String pas
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DBUtil.java:586
↓ 4 callersMethodtoString
()
common/src/main/java/com/alibaba/datax/common/statistics/PerfRecord.java:140
↓ 4 callersMethodtracePerfRecord
(PerfRecord perfRecord)
common/src/main/java/com/alibaba/datax/common/statistics/PerfTrace.java:120
↓ 4 callersMethodtryWrite
(Record record)
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/Neo4jClient.java:188
↓ 4 callersMethodvalueToLowerCase
(List<String> aList)
common/src/main/java/com/alibaba/datax/common/util/ListUtil.java:129
↓ 4 callersMethodwriteGroupType
(Type type, JSON value, int index)
osswriter/src/main/java/com/alibaba/datax/plugin/writer/osswriter/parquet/ParquetFileSupport.java:128
↓ 4 callersMethodwriteGroupType
(Type type, JSON value, int index)
hdfswriter/src/main/java/com/alibaba/datax/plugin/writer/hdfswriter/ParquetFileSupport.java:373
↓ 4 callersMethodwriteRemainingRecord
(List<Long> blocks)
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/OdpsWriterProxy.java:227
↓ 3 callersFunction_build_simple_row
Format row according to DataRow format without padding.
otsstreamreader/tools/tabulate.py:1086
↓ 3 callersFunction_isint
>>> _isint("123") True >>> _isint("123.45") False
otsstreamreader/tools/tabulate.py:360
↓ 3 callersFunction_prepend_row_index
Add a left-most index column.
otsstreamreader/tools/tabulate.py:626
↓ 3 callersMethodaddPart
(List partList)
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/PartInfo.java:24
↓ 3 callersMethodasBigDecimal
()
common/src/main/java/com/alibaba/datax/common/element/DoubleColumn.java:59
↓ 3 callersMethodasBoolean
()
common/src/main/java/com/alibaba/datax/common/element/BoolColumn.java:36
↓ 3 callersMethodasBytes
(final StringColumn column)
common/src/main/java/com/alibaba/datax/common/element/ColumnCast.java:134
↓ 3 callersMethodassertConfig
(String key, Supplier<Boolean> f)
gdbreader/src/main/java/com/alibaba/datax/plugin/reader/gdbreader/util/ConfigHelper.java:28
↓ 3 callersMethodbeautify
格式化Configuration输出
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:587
↓ 3 callersMethodcalStatistic
(final long cost)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/task/InsertTask.java:125
↓ 3 callersMethodcanRetry
(String otsErrorCode)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/RetryHelper.java:63
↓ 3 callersMethodcheckClosed
()
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/writer/DataXCsvWriter.java:237
↓ 3 callersMethodcheckHbaseTable
(Admin admin, TableName hTableName)
hbase11xwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xwriter/Hbase11xHelper.java:185
↓ 3 callersMethodcheckListAndGet
(Configuration param, String key, boolean isCheckEmpty)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/ParamChecker.java:52
↓ 3 callersMethodcheckPath
(final String path)
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:1044
← previousnext →501–600 of 5,539, ranked by callers