MCPcopy Create free account

hub / github.com/alibaba/DataX / functions

Functions5,539 in github.com/alibaba/DataX

↓ 10 callersMethodisOracleMode
(String mode)
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/ObReaderUtils.java:826
↓ 10 callersMethodisSupported
Whether current version is supported. @return true: supported; false: not yet!
opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/conn/Connection4TSDB.java:92
↓ 10 callersMethodisTimeseriesTable
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/config/OTSStreamReaderConfig.java:187
↓ 10 callersMethodsetDate
(int parameterIndex, Date x)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:103
↓ 10 callersMethodsetEndpoint
(String endpoint)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:78
↓ 10 callersMethodsqlValid
(String sql, DataBaseType dataBaseType)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DBUtil.java:762
↓ 10 callersMethodsubmit
Submit a callable task @param task
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/ExecutorTemplate.java:130
↓ 10 callersMethodtoString
必须提供toString的实现 <pre> &#064;Override public String toString() { return String.format(&quot;Code:[%s], Description:[%s]. &quot;, this.code, this.desc
common/src/main/java/com/alibaba/datax/common/spi/ErrorCode.java:32
↓ 9 callersMethodaddress
Get the address of Database. @return host+ip
opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/conn/Connection4TSDB.java:38
↓ 9 callersMethodasPrimitiveType
(org.apache.parquet.schema.Type type, Map<String, ParquetMeta> parquetMetaMap)
hdfsreader/src/main/java/com/alibaba/datax/plugin/reader/hdfsreader/DFSUtil.java:960
↓ 9 callersMethodasString
(final DateColumn column)
common/src/main/java/com/alibaba/datax/common/element/ColumnCast.java:174
↓ 9 callersMethodbuild
()
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/HttpPutBuilder.java:57
↓ 9 callersMethodcheckStringAndGet
(Configuration param, String key, boolean isTrim)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/utils/ParamChecker.java:15
↓ 9 callersMethodcollect
()
core/src/main/java/com/alibaba/datax/core/statistics/container/communicator/AbstractContainerCommunicator.java:58
↓ 9 callersMethodfillPrimaryKey
(List<PrimaryKeySchema> pkSchema, List<PrimaryKeyColumn> pk, PrimaryKeyValue fillValue)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/ParamChecker.java:318
↓ 9 callersMethodfromJson
(String json)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/model/StreamJob.java:165
↓ 9 callersMethodgetCollector
()
core/src/main/java/com/alibaba/datax/core/statistics/container/communicator/AbstractContainerCommunicator.java:30
↓ 9 callersMethodgetConnection
(String queryServerAddress, String serialization)
hbase20xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase20xsqlreader/HBase20SQLReaderHelper.java:68
↓ 9 callersMethodgetDatabase
()
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/Keys.java:67
↓ 9 callersMethodgetIndex
()
core/src/main/java/com/alibaba/datax/core/statistics/plugin/task/util/DirtyRecord.java:104
↓ 9 callersMethodgetKeys
获取Configuration下所有叶子节点的key <p/> <br> <p/> 对于<br> <p/> {"a": {"b": {"c": [0,1,2,3]}}, "x": "y"} <p/> 下属的key包括: a.b.c[0],a.b.c[1],a.b.c[2],a.b.c[3],x
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:634
↓ 9 callersMethodgetShardIds
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/model/StreamJob.java:65
↓ 9 callersMethodgetStatusTable
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/config/OTSStreamReaderConfig.java:115
↓ 9 callersMethodgetTable
()
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/Keys.java:71
↓ 9 callersMethodisOracleMode
()
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/util/ObWriterUtils.java:113
↓ 9 callersMethodisTimeseriesTable
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:175
↓ 9 callersMethodloadColumnMetas
(List<String> tables)
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/SchemaManager.java:94
↓ 9 callersMethodmerge
合并其他Configuration,并修改两者冲突的KV配置 @param another 合并加入的第三方Configuration @param updateWhenConflict 当合并双方出现KV冲突时候,选择更新当前KV,或者忽略该KV @r
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:664
↓ 9 callersMethodread
()
ossreader/src/main/java/com/alibaba/datax/plugin/reader/ossreader/OssInputStream.java:90
↓ 9 callersMethodsetDouble
(int parameterIndex, double x)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:83
↓ 9 callersMethodsetPassword
(String password)
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/load/AdsHelper.java:67
↓ 9 callersMethodsetTime
(int parameterIndex, Time x)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:113
↓ 9 callersMethodsetTransformerName
(String transformerName)
transformer/src/main/java/com/alibaba/datax/transformer/Transformer.java:19
↓ 9 callersMethodwriteBatch
table: [ "stb1", "stb2", "tb1", "tb2", "t1" ] stb1[ts,f1,f2] tags:[t1] stb2[ts,f1,f2,f3] tags:[t1,t2] 1. tables 表的的类型分成:stb(super table)/tb(sub table)
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java:149
↓ 8 callersMethodbuildQuerySql
(String column, String table, String where)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/reader/util/SingleTableSplitUtil.java:131
↓ 8 callersMethodclose
由于ObProxy存在bug,事务超时或事务被杀时,conn的close是没有响应的 @param rs @param stmt @param conn
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/ObReaderUtils.java:713
↓ 8 callersMethodcommit
()
milvuswriter/src/main/java/com/alibaba/datax/plugin/writer/milvuswriter/MilvusBufferWriter.java:60
↓ 8 callersMethoddescribeTable
(SyncClientInterface ots, String tableName)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/utils/OTSHelper.java:124
↓ 8 callersMethodexecuteSqlWithoutResultSet
(Statement stmt, String sql)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DBUtil.java:449
↓ 8 callersMethodgetBytes
()
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/WriterTuple.java:19
↓ 8 callersMethodgetCode
()
common/src/main/java/com/alibaba/datax/common/spi/ErrorCode.java:17
↓ 8 callersMethodgetColumnType
()
hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/HbaseColumnCell.java:63
↓ 8 callersMethodgetColumns
()
hbase11xsqlwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xsqlwriter/ThinClientPTable.java:83
↓ 8 callersMethodgetColumns
()
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/TaskContext.java:116
↓ 8 callersMethodgetColumns
()
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/ads/TableInfo.java:63
↓ 8 callersMethodgetConn
()
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/ext/ConnHolder.java:23
↓ 8 callersMethodgetEndTimestampMillis
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/config/OTSStreamReaderConfig.java:131
↓ 8 callersMethodgetInstance
()
core/src/main/java/com/alibaba/datax/core/taskgroup/TaskMonitor.java:27
↓ 8 callersMethodgetKey
()
hbase11xsqlwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xsqlwriter/ThinClientPTable.java:240
↓ 8 callersMethodgetName
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSColumn.java:68
↓ 8 callersMethodgetPeerPluginName
()
common/src/main/java/com/alibaba/datax/common/plugin/Pluginable.java:22
↓ 8 callersMethodgetStartTimestampMillis
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/config/OTSStreamReaderConfig.java:123
↓ 8 callersMethodgetThrowable
()
core/src/main/java/com/alibaba/datax/core/statistics/communication/Communication.java:79
↓ 8 callersMethodgsonBuilder
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/GsonParser.java:13
↓ 8 callersMethodincreaseCounter
(final String key, final long deltaValue)
core/src/main/java/com/alibaba/datax/core/statistics/communication/Communication.java:148
↓ 8 callersMethodloadTableMeta
(List<String> tables)
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/SchemaManager.java:63
↓ 8 callersMethodnoDefaultValue
()
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/config/Option.java:27
↓ 8 callersMethodparseArrayType
(final Neo4jProperty neo4JProperty, final String strValue,
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/adapter/ValueAdapter.java:81
↓ 8 callersMethodprintWorkingDirectory
()
ftpwriter/src/main/java/com/alibaba/datax/plugin/writer/ftpwriter/util/SftpHelperImpl.java:293
↓ 8 callersMethodquoteConstantValue
(String aString, DataBaseType dataBaseType)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/RdbmsRangeSplitWrap.java:87
↓ 8 callersMethodreset
()
core/src/main/java/com/alibaba/datax/core/statistics/communication/Communication.java:47
↓ 8 callersMethodrunSqlTaskWithRetry
(final Odps odps, final String sql, String tag)
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/util/OdpsUtil.java:316
↓ 8 callersMethodsetJobPluginCollector
@param jobPluginCollector the jobPluginCollector to set
common/src/main/java/com/alibaba/datax/common/plugin/AbstractJobPlugin.java:18
↓ 8 callersMethodsetPeerPluginJobConf
(Configuration peerPluginJobConf)
common/src/main/java/com/alibaba/datax/common/plugin/Pluginable.java:26
↓ 8 callersMethodtimestampColToBinary
int 96 is timestamp in parquet @param valueColumn @return
hdfswriter/src/main/java/com/alibaba/datax/plugin/writer/hdfswriter/ParquetFileSupport.java:271
↓ 7 callersMethodalign
(int num)
core/src/main/java/com/alibaba/datax/core/util/ClassSize.java:33
↓ 7 callersMethodcommit
Commit the current direct load operation. @throws SQLException if commit fails.
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/ObTableDirectLoad.java:73
↓ 7 callersMethoddoBatchRecordWithPartitionSort
@param bufferSize datax缓冲记录条数 @param batchSize datax向ads系统一次发送数据条数 @param buffer datax缓冲区 @param mode 实时表模式insert 或者 stream
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/insert/AdsInsertProxy.java:226
↓ 7 callersMethodexecuteWithRetry
对重试的封装,方法需要用户传入最大重试次数,最大的重试时间。 如果方法执行失败,方法会进入重试,每次重试之前,方法会sleep一段时间(sleep机制请参见 Common.getDelaySendMillinSeconds方法),直到重试次数达到上限,系统会抛出异常。 @param callable
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/RetryHelper.java:28
↓ 7 callersMethodforStrColumn
(final boolean numPattern, final String rule)
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/mapping/DefaultGdbMapper.java:131
↓ 7 callersMethodgetAttributeColumn
()
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/model/OTSConf.java:105
↓ 7 callersMethodgetCategory
()
odpswriter/src/main/java/com/alibaba/datax/plugin/writer/odpswriter/model/PartitionInfo.java:40
↓ 7 callersMethodgetCheckpoint
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/model/ShardCheckpoint.java:37
↓ 7 callersMethodgetColumnIndex
()
core/src/main/java/com/alibaba/datax/core/transport/transformer/TransformerExecution.java:107
↓ 7 callersMethodgetDataTable
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/config/OTSStreamReaderConfig.java:107
↓ 7 callersMethodgetDefaultValue
()
neo4jwriter/src/main/java/com/alibaba/datax/plugin/writer/neo4jwriter/config/Option.java:59
↓ 7 callersMethodgetInstance
()
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/mapping/MapperConfig.java:32
↓ 7 callersMethodgetInternal
()
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:772
↓ 7 callersMethodgetLabel
()
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/WriterTuple.java:16
↓ 7 callersMethodgetLabel
()
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksFlushTuple.java:17
↓ 7 callersMethodgetListColumnEntry
( Configuration configuration, final String path)
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/reader/UnstructuredStorageReaderUtil.java:491
↓ 7 callersMethodgetOriginalType
()
hdfsreader/src/main/java/com/alibaba/datax/plugin/reader/hdfsreader/ParquetMeta.java:23
↓ 7 callersMethodgetProject
()
adswriter/src/main/java/com/alibaba/datax/plugin/writer/adswriter/load/TransferProjectConf.java:56
↓ 7 callersMethodgetRetry
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:75
↓ 7 callersMethodgetRunnerCommunication
()
core/src/main/java/com/alibaba/datax/core/taskgroup/runner/AbstractRunner.java:110
↓ 7 callersMethodgetTableName
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:123
↓ 7 callersMethodgetTimestamp
(StreamRecord record)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/core/RecordProcessor.java:142
↓ 7 callersMethodgetValueType
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSColumn.java:72
↓ 7 callersMethodisRowkeyColumn
(String columnName)
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/util/ObHbaseReaderUtil.java:192
↓ 7 callersMethodparse
(String sp, String dSp)
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/row/StarRocksDelimiterParser.java:11
↓ 7 callersMethodparse
@param dataxCfg @return
hbase11xsqlwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xsqlwriter/HbaseSQLWriterConfig.java:110
↓ 7 callersMethodprintWorkingDirectory
()
ftpwriter/src/main/java/com/alibaba/datax/plugin/writer/ftpwriter/util/StandardFtpHelperImpl.java:293
↓ 7 callersMethodregistTransformer
(Transformer transformer)
core/src/main/java/com/alibaba/datax/core/transport/transformer/TransformerRegistry.java:122
↓ 7 callersMethodrollback
Rollback if error occurred. @throws SQLException
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/DirectPathConnection.java:98
↓ 7 callersMethodsetBegin
(List<PrimaryKeyColumn> begin)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSRange.java:16
↓ 7 callersMethodsetBytes
(Long bytes)
common/src/main/java/com/alibaba/datax/common/statistics/PerfTrace.java:843
↓ 7 callersMethodsetColumn
(int i, final Column column)
common/src/main/java/com/alibaba/datax/common/element/Record.java:13
↓ 7 callersMethodsetEnd
(List<PrimaryKeyColumn> end)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSRange.java:22
↓ 7 callersMethodsetFloat
(int parameterIndex, float x)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:78
↓ 7 callersMethodsetId
(final String id)
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/GdbElement.java:25
← previousnext →201–300 of 5,539, ranked by callers