MCPcopy Create free account

hub / github.com/alibaba/DataX / functions

Functions5,539 in github.com/alibaba/DataX

⨍ Functions 5,539◇ Types & classes 1,122
↓ 23 callersMethodgetRange
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:131
↓ 22 callersMethodclone
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/DefaultNoRetry.java:14
↓ 22 callersMethodgetByteSize
()
common/src/main/java/com/alibaba/datax/common/element/Record.java:21
↓ 22 callersMethodinit
Slave的初始化，创建Slave所使用的资源
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/IOtsWriterSlaveProxy.java:12
↓ 22 callersMethodparseArray
(JSONArray jsonArray, ArrayTypeInfo arrayTypeInfo)
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/OdpsWriterProxy.java:438
↓ 22 callersMethodsetLongCounter
(final String key, final long value)
core/src/main/java/com/alibaba/datax/core/statistics/communication/Communication.java:132
↓ 21 callersMethodend
()
common/src/main/java/com/alibaba/datax/common/statistics/PerfRecord.java:122
↓ 21 callersMethodentry
(final String[] args)
core/src/main/java/com/alibaba/datax/core/Engine.java:116
↓ 21 callersMethodflush
()
common/src/main/java/com/alibaba/datax/common/plugin/RecordSender.java:27
↓ 21 callersMethodgetKey
()
core/src/main/java/com/alibaba/datax/core/statistics/communication/CommunicationTool.java:271
↓ 21 callersMethodgetTaskId
()
common/src/main/java/com/alibaba/datax/common/statistics/PerfRecord.java:196
↓ 21 callersMethodtoJSONString
(final Object object)
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:1080
↓ 20 callersMethodgetColumnName
()
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/HbaseColumnCell.java:69
↓ 20 callersMethodgetVersion
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/model/StreamJob.java:57
↓ 20 callersMethodstart
()
common/src/main/java/com/alibaba/datax/common/statistics/PerfRecord.java:103
↓ 20 callersMethodtoJSON
将Configuration作为JSON输出
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:694
↓ 19 callersMethodget
(String url, String username, String password)
tsdbreader/src/main/java/com/alibaba/datax/plugin/reader/tsdbreader/util/HttpUtils.java:33
↓ 19 callersMethodkey
(String key)
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/config/Option.java:12
↓ 18 callersMethodadd
(int type, int sqlType, String jdbc, String[] names)
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/ads/ColumnDataType.java:96
↓ 18 callersMethodasyncResultSetNext
异步获取resultSet的next(),注意，千万不能应用在数据的读取中。只能用在meta的获取 @param resultSet @return
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DBUtil.java:772
↓ 18 callersMethodcreate
(Configuration adsWriterConf)
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/load/TransferProjectConf.java:24
↓ 18 callersMethodgetEnd
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSRange.java:19
↓ 18 callersMethodprepareStatement
A new batch need create a new {@link DirectPathPreparedStatement }. The {@link DirectPathPreparedStatement } can not be reuse, otherwise it may cause
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/DirectPathConnection.java:140
↓ 17 callersMethodbuild
()
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/jest/PutMapping7.java:33
↓ 17 callersMethodclose
释放Slave的所有资源
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/IOtsWriterSlaveProxy.java:17
↓ 17 callersMethodgetBytes
()
common/src/main/java/com/alibaba/datax/common/statistics/PerfTrace.java:711
↓ 17 callersMethodgetJarLoader
(PluginType pluginType, String pluginName)
core/src/main/java/com/alibaba/datax/core/util/container/LoadUtil.java:180
↓ 17 callersMethodsetNull
(OdpsType type,Object data, int limit, Boolean enableOverLengthOutput)
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/util/OdpsUtil.java:874
↓ 17 callersMethodsetPluginJobConf
(Configuration jobConf)
common/src/main/java/com/alibaba/datax/common/plugin/Pluginable.java:24
↓ 17 callersMethodstartRead
数据导出函数 @param recordSender @throws Exception
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/IOtsReaderSlaveProxy.java:25
↓ 16 callersMethodgetPrimaryKey
()
milvuswriter/src/main/java/com/alibaba/datax/plugin/writer/milvuswriter/MilvusColumn.java:65
↓ 16 callersMethodgetRetryExponential
(boolean retryExponential)
common/src/main/java/com/alibaba/datax/common/util/DataXCaseEnvUtil.java:28
↓ 16 callersMethodgetRetryInterval
(long retryInterval)
common/src/main/java/com/alibaba/datax/common/util/DataXCaseEnvUtil.java:22
↓ 16 callersMethodgetRetryTimes
(int retryTimes)
common/src/main/java/com/alibaba/datax/common/util/DataXCaseEnvUtil.java:16
↓ 16 callersMethodgetTaskGroupId
()
core/src/main/java/com/alibaba/datax/core/transport/channel/Channel.java:99
↓ 15 callersMethodasQueryException
(DataBaseType dataBaseType, Exception e,String querySql,String table,String userName)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/RdbmsException.java:71
↓ 15 callersMethodgetBegin
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSRange.java:13
↓ 15 callersMethodgetMap
根据用户提供的json path，寻址Map对象，如果对象不存在，返回null
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:487
↓ 15 callersMethodgetMetaData
()
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedConnection.java:58
↓ 15 callersMethodgetValue
()
core/src/main/java/com/alibaba/datax/core/statistics/communication/CommunicationTool.java:275
↓ 15 callersMethodquery
a wrapped method to execute select-like sql statement . @param conn Database connection . @param sql sql statement to be executed @return a {@link R
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DBUtil.java:409
↓ 15 callersMethodreadHeaderItem
(@Nonnull byte[] buf, @Nonnegative int len, @Nonnull Adler32 adler, @Nonnull CRC32 crc32)
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/reader/ExpandLzopInputStream.java:127
↓ 15 callersMethodrestoreCurrentThreadClassLoader
将当前线程的类加载器设置为保存的类加载 @return
core/src/main/java/com/alibaba/datax/core/util/container/ClassLoaderSwapper.java:35
↓ 15 callersMethodsetCurrentThreadClassLoader
保存当前classLoader，并将当前线程的classLoader设置为所给classLoader @param @return
core/src/main/java/com/alibaba/datax/core/util/container/ClassLoaderSwapper.java:25
↓ 15 callersMethodtoJson
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/model/StreamJob.java:155
↓ 14 callersMethodbuild
()
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/config/Option.java:31
↓ 14 callersMethodgetSize
()
ossreader/src/main/java/com/alibaba/datax/plugin/reader/ossreader/util/OssSplitUtil.java:453
↓ 14 callersMethodgetTaskGroupId
@return the taskGroupId
core/src/main/java/com/alibaba/datax/core/taskgroup/runner/AbstractRunner.java:91
↓ 14 callersMethodgetType
()
hbase11xsqlwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xsqlwriter/ThinClientPTable.java:68
↓ 14 callersMethodsetAutoCommit
(boolean autoCommit)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedConnection.java:33
↓ 14 callersMethodsetBoolean
(int parameterIndex, boolean x)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:53
↓ 14 callersMethodsleep
休眠n毫秒 @param ms 毫秒
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/util/ObWriterUtils.java:375
↓ 13 callersMethodasBigInteger
()
common/src/main/java/com/alibaba/datax/common/element/Column.java:67
↓ 13 callersMethodassertHasContent
(final Configuration config, final String key)
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/util/ConfigHelper.java:29
↓ 13 callersMethodclose
()
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/writer/UnstructuredWriter.java:13
↓ 13 callersMethoddesc
(String desc)
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/config/Option.java:17
↓ 13 callersMethodgetDouble
根据用户提供的json path，寻址Double对象 @return Double对象，如果path不存在或者Double不存在，返回null
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:373
↓ 13 callersMethodgetPrimaryKeyColumn
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:56
↓ 13 callersMethodgetSchema
Return the schema name of this connection instance. @return String
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/DirectPathConnection.java:156
↓ 13 callersMethodgetStreamId
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/model/StreamJob.java:49
↓ 13 callersMethodgetTable
()
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/TaskContext.java:128
↓ 13 callersMethodgetTaskId
()
core/src/main/java/com/alibaba/datax/core/taskgroup/runner/AbstractRunner.java:95
↓ 13 callersMethodgetTransformerName
()
core/src/main/java/com/alibaba/datax/core/transport/transformer/TransformerExecution.java:111
↓ 13 callersMethodrun
()
core/src/main/java/com/alibaba/datax/core/taskgroup/runner/WriterRunner.java:32
↓ 13 callersMethodsetInt
(int parameterIndex, int x)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:68
↓ 13 callersMethodsetTimestamp
(long timestamp)
core/src/main/java/com/alibaba/datax/core/statistics/communication/Communication.java:103
↓ 12 callersMethodgetContainerCommunicator
()
core/src/main/java/com/alibaba/datax/core/AbstractContainer.java:25
↓ 12 callersMethodgetError
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/LineAndError.java:18
↓ 12 callersMethodgetErrorMessage
(final Communication communication)
core/src/main/java/com/alibaba/datax/core/statistics/communication/CommunicationTool.java:253
↓ 12 callersMethodgetRows
()
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/WriterTuple.java:19
↓ 12 callersMethodgetState
()
core/src/main/java/com/alibaba/datax/core/statistics/communication/Communication.java:63
↓ 12 callersMethodrenderPreOrPostSqls
(List<String> preOrPostSqls, String tableName)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/util/WriterUtil.java:79
↓ 12 callersMethodsetParameter
Set parameter to the target position. @param parameterIndex Start From 1 @param obObj Convert original value to {@link ObObj } @throws SQLEx
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/DirectPathPreparedStatement.java:147
↓ 12 callersMethodsetTimestamp
(long timestamp)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:150
↓ 11 callersMethodasBigDecimal
()
common/src/main/java/com/alibaba/datax/common/element/Column.java:65
↓ 11 callersMethodassertConfig
(final String key, final Supplier<Boolean> f)
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/util/ConfigHelper.java:23
↓ 11 callersMethodcollectDirtyRecord
(Record record, Throwable throwable)
obhbasewriter/src/main/java/com/alibaba/datax/plugin/writer/obhbasewriter/task/ObHBaseWriteTask.java:201
↓ 11 callersMethodexecute
(Action<T> clientRequest)
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/ElasticSearchClient.java:202
↓ 11 callersMethodgetBytes
()
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksFlushTuple.java:19
↓ 11 callersMethodgetMemorySize
()
common/src/main/java/com/alibaba/datax/common/element/Record.java:23
↓ 11 callersMethodgetOrDefault
(Supplier<String> dateFormat, String defaultFormat)
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/adapter/DateAdapter.java:35
↓ 11 callersMethodgetTimestamp
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:147
↓ 11 callersMethodgetTotalReadRecords
(final Communication communication)
core/src/main/java/com/alibaba/datax/core/statistics/communication/CommunicationTool.java:83
↓ 11 callersMethodgetWhere
()
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/TaskContext.java:96
↓ 11 callersMethodgsonBuilder
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/GsonParser.java:20
↓ 11 callersMethodnewDefault
初始化空白的Configuration
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:67
↓ 11 callersMethodof
(final Configuration config)
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/client/GdbWriterConfig.java:34
↓ 11 callersMethodsetLong
(int parameterIndex, long x)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:73
↓ 11 callersMethodsetMaxVersions
(Scan scan)
hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/MultiVersionTask.java:91
↓ 10 callersMethodasString
()
common/src/main/java/com/alibaba/datax/common/element/StringColumn.java:25
↓ 10 callersMethodexecuteSqls
(Connection conn, List<String> sqls, String basicMessage,DataBaseType dataBaseType)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/util/WriterUtil.java:95
↓ 10 callersMethodfill
(FileBlock fileBlock)
ossreader/src/main/java/com/alibaba/datax/plugin/reader/ossreader/util/OssSplitUtil.java:290
↓ 10 callersMethodgetDescription
()
common/src/main/java/com/alibaba/datax/common/spi/ErrorCode.java:20
↓ 10 callersMethodgetOperation
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:50
↓ 10 callersMethodgetRecords
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSLine.java:66
↓ 10 callersMethodgetRetry
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:111
↓ 10 callersMethodgetSleepInMillisecond
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:117
↓ 10 callersMethodgetTableName
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:99
↓ 10 callersMethodgetTypeName
TODO: 在7.0开始，一个索引只能建一个Type为_doc
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/Key.java:99
↓ 10 callersMethodgetValue
()
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/GdbElement.java:105
← previousnext →101–200 of 5,539, ranked by callers