MCPcopy Create free account

hub / github.com/alibaba/DataX / functions

Functions5,539 in github.com/alibaba/DataX

⨍ Functions 5,539◇ Types & classes 1,122
↓ 5 callersMethodgetPassword
()
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/StarRocksWriterOptions.java:102
↓ 5 callersMethodgetSequenceInfo
(StreamRecord streamRecord, int colIdx)
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/core/MultiVerModeRecordSender.java:135
↓ 5 callersMethodgetStatus
()
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/common/Table.java:25
↓ 5 callersMethodgetStreamLoadFormat
()
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/Keys.java:143
↓ 5 callersMethodgetStreamLoadFormat
()
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/StarRocksWriterOptions.java:165
↓ 5 callersMethodgetTableMeta
(SyncClientInterface ots, String tableName, int retry, int sleepInMillisecond)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/OtsHelper.java:51
↓ 5 callersMethodgetTimestamp
()
core/src/main/java/com/alibaba/datax/core/statistics/communication/Communication.java:99
↓ 5 callersMethodgetTo
()
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/GdbEdge.java:33
↓ 5 callersMethodgetUsername
()
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/Keys.java:75
↓ 5 callersMethodgetUsername
()
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/Keys.java:78
↓ 5 callersMethodgetUsername
()
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/StarRocksWriterOptions.java:98
↓ 5 callersMethodinit
()
tdenginereader/src/main/java/com/alibaba/datax/plugin/reader/TDengineReader.java:30
↓ 5 callersMethodinitConnection
()
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/ext/ConnHolder.java:17
↓ 5 callersMethodisRowkeyColumn
(String columnName)
hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/Hbase11xHelper.java:213
↓ 5 callersMethodisRowkeyColumn
(String columnName)
hbase094xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase094xreader/Hbase094xHelper.java:168
↓ 5 callersMethodjsonToConf
(String jsonStr)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/utils/GsonParser.java:42
↓ 5 callersMethodmessageWithDefaultMessage
(String code, String defaultMessage)
common/src/main/java/com/alibaba/datax/common/util/MessageSource.java:182
↓ 5 callersMethodparseConfig
(Configuration cfg)
hbase11xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xsqlreader/HbaseSQLHelper.java:125
↓ 5 callersFunctionparseJson
(strConfig, context)
core/src/main/bin/perftrace.py:303
↓ 5 callersMethodpost
()
core/src/main/java/com/alibaba/datax/core/job/JobContainer.java:559
↓ 5 callersMethodprepare
()
core/src/main/java/com/alibaba/datax/core/job/JobContainer.java:307
↓ 5 callersMethodproduceUnstructuredWriter
(String fileFormat, Configuration config, Writer writer)
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/writer/UnstructuredStorageWriterUtil.java:268
↓ 5 callersMethodreportTaskGroupCommunication
(Communication lastTaskGroupContainerCommunication, int taskCount)
core/src/main/java/com/alibaba/datax/core/taskgroup/TaskGroupContainer.java:338
↓ 5 callersMethodsetBigDecimal
(int parameterIndex, BigDecimal x)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedPreparedStatement.java:88
↓ 5 callersMethodsetColumnType
(ColumnType columnType)
odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/InternalColumnInfo.java:21
↓ 5 callersMethodsetEntity
(HttpEntity httpEntity)
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/HttpPutBuilder.java:52
↓ 5 callersMethodsetFrom
(final String from)
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/GdbEdge.java:25
↓ 5 callersMethodsetLabel
(final String label)
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/GdbElement.java:37
↓ 5 callersMethodsetTaskPluginCollector
(TaskPluginCollector pluginCollector)
core/src/main/java/com/alibaba/datax/core/taskgroup/runner/AbstractRunner.java:53
↓ 5 callersMethodsetTimeZone
(String timezone)
elasticsearchwriter/src/main/java/com/alibaba/datax/plugin/writer/elasticsearchwriter/ElasticSearchColumn.java:67
↓ 5 callersMethodsetTo
(final String to)
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/GdbEdge.java:37
↓ 5 callersMethodsetValueType
(ColumnType valueType)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSColumn.java:76
↓ 5 callersMethodstart
(Configuration allConf)
core/src/main/java/com/alibaba/datax/core/Engine.java:40
↓ 5 callersMethodtoJSonString
(Object o, DataType type )
cassandrareader/src/main/java/com/alibaba/datax/plugin/reader/cassandrareader/CassandraReaderHelper.java:56
↓ 5 callersMethodtransIntervalDayTimeToJavaMap
(IntervalDayTime dayTime)
odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/ReaderProxy.java:822
↓ 5 callersMethodtransIntervalYearMonthToJavaMap
(IntervalYearMonth yearMonth)
odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/ReaderProxy.java:914
↓ 5 callersMethodtransOdpsArrayToJavaList
(List odpsArray, ArrayTypeInfo typeInfo)
odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/ReaderProxy.java:458
↓ 5 callersMethodtransOdpsStructToJavaMap
(Struct odpsStruct)
odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/ReaderProxy.java:829
↓ 5 callersMethodunitTime
(long time)
common/src/main/java/com/alibaba/datax/common/statistics/PerfTrace.java:238
↓ 5 callersMethodunwrap
(Class<T> iface)
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/directPath/AbstractRestrictedConnection.java:248
↓ 5 callersMethodwrapRange
(long[] rangeResult, String columnName)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/RdbmsRangeSplitWrap.java:29
↓ 5 callersMethodwritePrimitiveType
(Type type, Object value, int index)
osswriter/src/main/java/com/alibaba/datax/plugin/writer/osswriter/parquet/ParquetFileSupport.java:250
↓ 5 callersMethodwritePrimitiveType
(Type type, Object value, int index)
hdfswriter/src/main/java/com/alibaba/datax/plugin/writer/hdfswriter/ParquetFileSupport.java:494
↓ 4 callersFunction_build_line
Return a string which represents a horizontal line.
otsstreamreader/tools/tabulate.py:1102
↓ 4 callersFunction_build_row
Return a string which represents a row of data cells.
otsstreamreader/tools/tabulate.py:1092
↓ 4 callersFunction_strip_invisible
Remove invisible ANSI color codes.
otsstreamreader/tools/tabulate.py:469
↓ 4 callersMethodaccept
(File pathname)
core/src/main/java/com/alibaba/datax/core/util/container/JarLoader.java:75
↓ 4 callersMethodaddProperty
(final String propKey, final Object propValue, final PropertyType card)
gdbwriter/src/main/java/com/alibaba/datax/plugin/writer/gdbwriter/model/GdbElement.java:49
↓ 4 callersMethodasDouble
()
core/src/main/java/com/alibaba/datax/core/statistics/plugin/task/util/DirtyRecord.java:118
↓ 4 callersMethodasLong
()
core/src/main/java/com/alibaba/datax/core/statistics/plugin/task/util/DirtyRecord.java:112
↓ 4 callersMethodasPostSQLParserException
(DataBaseType dataBaseType, Exception e,String querySql)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/RdbmsException.java:145
↓ 4 callersMethodasPreSQLParserException
(DataBaseType dataBaseType, Exception e,String querySql)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/RdbmsException.java:134
↓ 4 callersMethodasyncClose
由于ObProxy存在bug,事务超时或事务被杀时,conn的close是没有响应的 @param rs @param stmt @param conn
oceanbasev10writer/src/main/java/com/alibaba/datax/plugin/writer/oceanbasev10writer/util/ObWriterUtils.java:476
↓ 4 callersMethodbuild
()
hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/HbaseColumnCell.java:118
↓ 4 callersMethodbuildColumn
(String columnValue, ColumnType columnType, String encoding, String dateformat, String timezone)
obhbasereader/src/main/java/com/alibaba/datax/plugin/reader/obhbasereader/util/ObHbaseReaderUtil.java:251
↓ 4 callersMethodbuildColumn
(String name, ColumnValue value, long timestamp)
otswriter/src/main/java/com/alibaba/datax/plugin/writer/otswriter/utils/ParseRecord.java:26
↓ 4 callersMethodbuildColumnValue
(ColumnMeta colMeta, Record record)
tdenginewriter/src/main/java/com/alibaba/datax/plugin/writer/tdenginewriter/DefaultDataHandler.java:288
↓ 4 callersMethodbuildObject
(final List<String> paths, final Object object)
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:825
↓ 4 callersMethodcheckFlushException
()
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisWriterManager.java:187
↓ 4 callersMethodcheckFlushException
()
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/SelectdbWriterManager.java:191
↓ 4 callersMethodcheckFlushException
()
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksWriterManager.java:198
↓ 4 callersMethodcheckNotNull
(T reference)
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/SelectdbUtil.java:106
↓ 4 callersMethodclear
()
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/reader/binaryFileUtil/ByteUtils.java:43
↓ 4 callersMethodcloseClient
(KuduClient kuduClient)
kuduwriter/src/main/java/com/q1/datax/plugin/writer/kudu11xwriter/Kudu11xHelper.java:195
↓ 4 callersMethodcloseConnection
(Connection hConnection)
hbase11xwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xwriter/Hbase11xHelper.java:148
↓ 4 callersMethodcloseJdbc
(Connection connection, Statement statement, ResultSet resultSet)
hbase20xsqlwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase20xsqlwriter/HBase20xSQLHelper.java:127
↓ 4 callersMethodcloseJdbc
(Connection connection, Statement statement, ResultSet resultSet)
hbase20xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase20xsqlreader/HBase20SQLReaderHelper.java:140
↓ 4 callersMethodconfig
Get these configurations. @return configs
opentsdbreader/src/main/java/com/alibaba/datax/plugin/reader/conn/Connection4TSDB.java:52
↓ 4 callersMethodconvertBytesToAssignType
(ColumnType columnType, byte[] byteArray,String dateformat)
hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/HbaseAbstractTask.java:91
↓ 4 callersMethodconvertBytesToAssignType
(ColumnType columnType, byte[] byteArray,String dateformat)
hbase094xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase094xreader/HbaseAbstractTask.java:90
↓ 4 callersMethodcreateBatchLabel
()
doriswriter/src/main/java/com/alibaba/datax/plugin/writer/doriswriter/DorisWriterManager.java:119
↓ 4 callersMethodcreateBatchLabel
()
selectdbwriter/src/main/java/com/alibaba/datax/plugin/writer/selectdbwriter/SelectdbWriterManager.java:125
↓ 4 callersMethodcreateBatchLabel
()
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/manager/StarRocksWriterManager.java:128
↓ 4 callersMethoddealWithSessionConfig
(Connection conn, Configuration config, DataBaseType databaseType
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DBUtil.java:703
↓ 4 callersMethoddecimalToBinary
(Column value, int precision, int scale)
hdfswriter/src/main/java/com/alibaba/datax/plugin/writer/hdfswriter/ParquetFileSupport.java:236
↓ 4 callersMethoddecryptBASE64
BASE64解密 @param cipherText @return @throws Exception
core/src/main/java/com/alibaba/datax/core/util/SecretUtil.java:70
↓ 4 callersMethoddefaultExecutor
@param poolName @return ExecutorService
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/ExecutorTemplate.java:102
↓ 4 callersMethoddeleteDir
(Path path)
hdfswriter/src/main/java/com/alibaba/datax/plugin/writer/hdfswriter/HdfsHelper.java:200
↓ 4 callersMethoddoDealWithSessionConfig
(Connection conn, List<String> sessions, String message)
plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/util/DBUtil.java:733
↓ 4 callersMethodencryptBASE64
BASE64加密 @param plaintextBytes @return @throws Exception
core/src/main/java/com/alibaba/datax/core/util/SecretUtil.java:59
↓ 4 callersMethodgetAbsolutePathFromClassPath
(String path)
datax-example/datax-example-core/src/main/java/com/alibaba/datax/example/util/PathUtil.java:15
↓ 4 callersMethodgetBuffer
()
plugin-unstructured-storage-util/src/main/java/com/alibaba/datax/plugin/unstructuredstorage/reader/binaryFileUtil/ByteUtils.java:15
↓ 4 callersMethodgetByTypeName
(String typeName)
obhbasewriter/src/main/java/com/alibaba/datax/plugin/writer/obhbasewriter/ColumnType.java:33
↓ 4 callersMethodgetByTypeName
(String typeName)
hbase11xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xreader/ColumnType.java:29
↓ 4 callersMethodgetByTypeName
(String typeName)
hbase094xwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase094xwriter/ColumnType.java:26
↓ 4 callersMethodgetByTypeName
(String typeName)
hbase094xreader/src/main/java/com/alibaba/datax/plugin/reader/hbase094xreader/ColumnType.java:29
↓ 4 callersMethodgetByTypeName
(String typeName)
hbase11xwriter/src/main/java/com/alibaba/datax/plugin/writer/hbase11xwriter/ColumnType.java:27
↓ 4 callersMethodgetChar
根据用户提供的json path，寻址Character对象 @return Character对象，如果path不存在或者Character不存在，返回null
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:236
↓ 4 callersMethodgetColumnName
()
odpsreader/src/main/java/com/alibaba/datax/plugin/reader/odpsreader/InternalColumnInfo.java:9
↓ 4 callersMethodgetColumns
()
starrockswriter/src/main/java/com/starrocks/connector/datax/plugin/writer/starrockswriter/StarRocksWriterOptions.java:114
↓ 4 callersMethodgetColumns
@return 返回所有的列，包括主键列和非主键列，但不包括version列
hbase11xsqlreader/src/main/java/com/alibaba/datax/plugin/reader/hbase11xsqlreader/HbaseSQLReaderConfig.java:58
↓ 4 callersMethodgetCommunication
()
core/src/main/java/com/alibaba/datax/core/statistics/plugin/task/AbstractTaskPluginCollector.java:35
↓ 4 callersMethodgetConfiguration
用户指定部分path，获取Configuration的子集 <p/> <br> 如果path获取的路径或者对象不存在，返回null
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:194
↓ 4 callersMethodgetConfigurationsFromRanges
(List<OTSRange> ranges)
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/OtsReaderMasterProxy.java:212
↓ 4 callersMethodgetConn
()
oceanbasev10reader/src/main/java/com/alibaba/datax/plugin/reader/oceanbasev10reader/util/TaskContext.java:58
↓ 4 callersMethodgetConnectionWithoutRetry
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:340
↓ 4 callersMethodgetCursorWithRetry
(final Client client, final String project, final String logstore, final int shard, final long fromTime)
loghubreader/src/main/java/com/alibaba/datax/plugin/reader/loghubreader/LogHubReader.java:281
↓ 4 callersMethodgetEndTimeInMillis
()
otsstreamreader/src/main/java/com/alibaba/datax/plugin/reader/otsstreamreader/internal/model/StreamJob.java:81
↓ 4 callersMethodgetEndpoint
()
otsreader/src/main/java/com/alibaba/datax/plugin/reader/otsreader/model/OTSConf.java:91
↓ 4 callersMethodgetIndex
(final String index)
common/src/main/java/com/alibaba/datax/common/util/Configuration.java:1024
← previousnext →401–500 of 5,539, ranked by callers