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
↓ 1,217 callers
Method
getString
根据用户提供的json path,寻址String对象 @return String对象,如果path不存在或者String不存在,返回null
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:208
↓ 1,204 callers
Method
asDataXException
(ErrorCode errorCode, String message)
common/src/main/java/com/alibaba/datax/common/exception/DataXException.java:29
↓ 749 callers
Method
info
日志打印控制 @param logger @param message
loghubwriter/src/main/java/com/alibaba/datax/plugin/writer/loghubwriter/LogHubWriter.java:310
↓ 681 callers
Method
add
(List<Tuple2<Record, GdbElement>> records)
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/GdbGraph.java:17
↓ 620 callers
Method
append
(byte[] buf)
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/reader/binaryFileUtil/ByteUtils.java:32
↓ 620 callers
Method
size
()
core/src/main/java/com/alibaba/datax/core/transport/channel/Channel.java:162
↓ 442 callers
Method
toString
()
common/src/main/java/com/alibaba/datax/common/element/Record.java:17
↓ 438 callers
Method
put
Put data point. @param dp data point @return whether the data point is written successfully
opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/conn/Connection4TSDB.java:77
↓ 434 callers
Method
set
根据用户提供的json path,插入指定对象,并返回之前存在的对象(如果存在) <p/> <br> <p/> 目前仅支持.以及数组下标寻址, 例如: <p/> <br /> <p/> config.set("a.b.c[3]", object); <p/> <br> 对于插入对象,Configur
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:613
↓ 402 callers
Method
get
根据用户提供的json path,寻址具体的对象。 <p/> <br> <p/> NOTE: 目前仅支持Map以及List下标寻址, 例如: <p/> <br /> <p/> 对于如下JSON <p/> {"a": {"b": {"c": [0,1,2,3]}}} <p/> config.get("
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:179
↓ 348 callers
Method
getMessage
从Task获取自定义收集信息
common/src/main/java/com/alibaba/datax/common/plugin/JobPluginCollector.java:15
↓ 343 callers
Method
get
(String url)
opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/util/HttpUtils.java:45
↓ 288 callers
Method
getInt
根据用户提供的json path,寻址Integer对象 @return Integer对象,如果path不存在或者Integer不存在,返回null
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:305
↓ 265 callers
Method
equalsIgnoreCase
(String fileFormat)
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/FileFormat.java:57
↓ 258 callers
Method
addColumn
(Column column)
common/src/main/java/com/alibaba/datax/common/element/Record.java:11
↓ 245 callers
Method
getList
根据用户提供的json path,寻址List对象,如果对象不存在,返回null
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:405
↓ 243 callers
Method
valueOf
(String version)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/util/ObVersion.java:53
↓ 238 callers
Method
asString
()
common/src/main/java/com/alibaba/datax/common/element/Column.java:55
↓ 234 callers
Method
getName
返回名字 @return
common/src/main/java/com/alibaba/datax/common/spi/Hook.java:17
↓ 212 callers
Method
isEmpty
()
core/src/main/java/com/alibaba/datax/core/transport/channel/Channel.java:164
↓ 205 callers
Method
equals
(Object object)
common/src/main/java/com/alibaba/datax/common/base/BaseObject.java:15
↓ 190 callers
Method
message
(String code)
common/src/main/java/com/alibaba/datax/common/util/MessageSource.java:158
↓ 180 callers
Method
getColumn
(int i)
common/src/main/java/com/alibaba/datax/common/element/Record.java:15
↓ 176 callers
Method
getBool
根据用户提供的json path,寻址Boolean对象 @return Boolean对象,如果path值非true,false ,将报错.特别注意:当 path 不存在时,会返回:null.
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:270
↓ 175 callers
Method
getPluginJobConf
()
common/src/main/java/com/alibaba/datax/common/plugin/Pluginable.java:18
↓ 170 callers
Method
getNecessaryValue
(String key, ErrorCode errorCode)
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:131
↓ 143 callers
Method
split
(int mandatoryNumber)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/IOtsWriterMasterProxy.java:13
↓ 123 callers
Method
getKey
()
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/config/Option.java:51
↓ 116 callers
Method
execute
(List<OTSLine> lines)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSTaskManagerInterface.java:6
↓ 109 callers
Method
getRawData
()
common/src/main/java/com/alibaba/datax/common/element/Column.java:27
↓ 103 callers
Method
getLong
根据用户提供的json path,寻址Long对象 @return Long对象,如果path不存在或者Long不存在,返回null
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:339
↓ 102 callers
Method
loadResourceBundle
@param baseName demo: javax.servlet.http.LocalStrings @throws MissingResourceException - if no resource bundle for the specifi
common/src/main/java/com/alibaba/datax/common/util/MessageSource.java:36
↓ 101 callers
Method
getValue
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSColumn.java:59
↓ 99 callers
Method
asLong
()
common/src/main/java/com/alibaba/datax/common/element/Column.java:51
↓ 98 callers
Method
getColumnNumber
()
common/src/main/java/com/alibaba/datax/common/element/Record.java:19
↓ 96 callers
Method
close
()
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/GdbGraph.java:19
↓ 95 callers
Method
toJSONString
()
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/reader/ColumnEntry.java:65
↓ 89 callers
Method
isEmpty
()
ossreader/src/main/java/com/alibaba/datax/plugin/reader/ossreader/util/OssSplitUtil.java:317
↓ 84 callers
Method
getTaskPluginCollector
()
common/src/main/java/com/alibaba/datax/common/plugin/AbstractTaskPlugin.java:13
↓ 81 callers
Method
getTime
(String v)
loghubwriter/src/main/java/com/alibaba/datax/plugin/writer/loghubwriter/LogHubWriter.java:139
↓ 79 callers
Method
destroy
()
common/src/main/java/com/alibaba/datax/common/plugin/Pluginable.java:14
↓ 79 callers
Method
get
()
core/src/main/java/com/alibaba/datax/core/transport/record/TerminateRecord.java:18
↓ 77 callers
Method
closeDBResources
(ResultSet rs, Statement stmt, Connection conn)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DBUtil.java:477
↓ 72 callers
Method
compareTo
(PerfRecord o)
common/src/main/java/com/alibaba/datax/common/statistics/PerfRecord.java:147
↓ 70 callers
Method
equals
(Object o)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/common/Table.java:33
↓ 69 callers
Method
from
从JSON字符串加载Configuration
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:74
↓ 67 callers
Method
replace
(String var0, String var1, String var2)
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/writer/DataXCsvWriter.java:248
↓ 66 callers
Method
clone
拷贝当前Configuration,注意,这里使用了深拷贝,避免冲突
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:701
↓ 66 callers
Method
getConnection
Get direct JDBC connection <p/> if connecting failed, try to connect for MAX_TRY_TIMES times <p/> NOTE: In DataX, we don't need connection pool in fac
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DBUtil.java:300
↓ 66 callers
Method
init
()
common/src/main/java/com/alibaba/datax/common/plugin/Pluginable.java:12
↓ 64 callers
Method
createStatement
@return DirectPathPreparedStatement
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/DirectPathConnection.java:129
↓ 64 callers
Method
indexOf
(String colName)
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java:560
↓ 61 callers
Method
clear
()
core/src/main/java/com/alibaba/datax/core/transport/channel/Channel.java:166
↓ 58 callers
Method
collect
(Record dirtyRecord, String errorMessage)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/CollectorUtil.java:17
↓ 56 callers
Method
executeWithRetry
重试次数工具方法. @param callable 实际逻辑 @param retryTimes 最大重试次数(>1) @param sleepTimeInMilliSecond 运行失败后休眠对应时间再重试 @param exponential
common/src/main/java/com/alibaba/datax/common/util/RetryUtil.java:25
↓ 55 callers
Method
collectDirtyRecord
收集脏数据 @param dirtyRecord 脏数据信息 @param t 异常信息 @param errorMessage 错误的提示信息
common/src/main/java/com/alibaba/datax/common/plugin/TaskPluginCollector.java:24
↓ 55 callers
Method
getBytes
()
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/WriterTuple.java:18
↓ 55 callers
Method
getLongCounter
(final String key)
core/src/main/java/com/alibaba/datax/core/statistics/communication/Communication.java:126
↓ 52 callers
Method
parse
指定Job配置路径,ConfigParser会解析Job、Plugin、Core全部信息,并以Configuration返回
core/src/main/java/com/alibaba/datax/core/util/ConfigParser.java:25
↓ 52 callers
Method
remove
删除path对应的值,如果path不存在,将抛出异常。
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:643
↓ 51 callers
Method
equals
(Column column, ColumnMeta colMeta)
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java:513
↓ 49 callers
Method
equals
(Object o)
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/util/ColumnTypeUtil.java:58
↓ 48 callers
Method
asDate
()
common/src/main/java/com/alibaba/datax/common/element/Column.java:57
↓ 48 callers
Method
asDouble
()
common/src/main/java/com/alibaba/datax/common/element/Column.java:53
↓ 47 callers
Method
getListConfiguration
根据用户提供的json path,寻址包含Configuration的List,如果对象不存在,返回默认null
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:471
↓ 46 callers
Method
createRecord
()
common/src/main/java/com/alibaba/datax/common/plugin/RecordSender.java:23
↓ 46 callers
Method
getValue
()
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/model/PartitionInfo.java:80
↓ 43 callers
Method
getFromReader
()
common/src/main/java/com/alibaba/datax/common/plugin/RecordReceiver.java:23
↓ 43 callers
Method
getShardId
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/model/ShardCheckpoint.java:21
↓ 43 callers
Method
getType
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSPrimaryKeyColumn.java:15
↓ 42 callers
Method
executeQuery
(String sql)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:509
↓ 41 callers
Method
getErrorCode
()
common/src/main/java/com/alibaba/datax/common/exception/DataXException.java:51
↓ 40 callers
Method
setObject
(int parameterIndex, Object x)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:133
↓ 39 callers
Method
build
(Configuration config, TaskPluginCollector taskPluginCollector)
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/Neo4jClient.java:62
↓ 38 callers
Method
asBoolean
()
common/src/main/java/com/alibaba/datax/common/element/Column.java:63
↓ 38 callers
Method
getType
()
common/src/main/java/com/alibaba/datax/common/element/Column.java:31
↓ 38 callers
Method
getValue
()
core/src/main/java/com/alibaba/datax/core/job/meta/ExecuteMode.java:19
↓ 37 callers
Method
get
(String url, String username, String password)
tsdbwriter/src/main/java/com/alibaba/datax/plugin/writer/util/HttpUtils.java:34
↓ 36 callers
Method
sendToWriter
(Record record)
common/src/main/java/com/alibaba/datax/common/plugin/RecordSender.java:25
↓ 35 callers
Method
equalsIgnoreCase
(String str1, String str2)
core/src/main/java/com/alibaba/datax/dataxservice/face/domain/enums/ExecuteMode.java:41
↓ 35 callers
Method
sleep
(int ms)
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/ObReaderUtils.java:105
↓ 35 callers
Method
write
Slave的执行器,将Datax的数据写入到OTS中 @param recordReceiver @throws OTSCriticalException
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/IOtsWriterSlaveProxy.java:24
↓ 34 callers
Method
equals
(Object obj)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/model/ShardCheckpoint.java:87
↓ 34 callers
Method
getType
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSAttrColumn.java:35
↓ 32 callers
Method
builder
()
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/config/Option.java:47
↓ 32 callers
Method
getConfiguration
()
core/src/main/java/com/alibaba/datax/core/transport/channel/Channel.java:111
↓ 32 callers
Method
value
()
core/src/main/java/com/alibaba/datax/dataxservice/face/domain/enums/EnumVal.java:4
↓ 30 callers
Method
addColumn
(Column column)
core/src/main/java/com/alibaba/datax/core/transport/record/DefaultRecord.java:36
↓ 30 callers
Method
setString
(int parameterIndex, String x)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:93
↓ 30 callers
Method
shutdown
()
common/src/main/java/com/alibaba/datax/common/plugin/RecordSender.java:31
↓ 28 callers
Method
getColumnType
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSColumn.java:63
↓ 26 callers
Method
createObObj
Create a {@link ObObj } instance. @param value Original column value @return ObObj
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:365
↓ 26 callers
Method
getId
()
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/GdbElement.java:21
↓ 26 callers
Method
getInstance
单实例 @param isJob @param jobId @param taskGroupId @return
common/src/main/java/com/alibaba/datax/common/statistics/PerfTrace.java:56
↓ 25 callers
Method
getFields
()
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/conn/DataPoint4MultiFieldsTSDB.java:56
↓ 24 callers
Method
apply
()
common/src/main/java/com/alibaba/datax/common/util/LoggerFunction.java:9
↓ 24 callers
Method
asBytes
()
common/src/main/java/com/alibaba/datax/common/element/Column.java:61
↓ 24 callers
Method
connect
(DataBaseType dataBaseType, String url, String user, String
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DBUtil.java:352
↓ 24 callers
Method
getTableName
()
hbase11xsqlwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xsqlwriter/ThinClientPTable.java:58
↓ 24 callers
Method
setParameter
Set parameter to the target position. @param parameterIndex @param obObj @throws SQLException
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:302
next →
1–100 of 5,539, ranked by callers