A B C D E F G H I K L M N O P Q R S T U V W

A

AdbForPgSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

ADB_PostgreSQL sourceDTO

AdbForPgSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.AdbForPgSourceDTO

addFilter(Filter) - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.FilterList

添加一个过滤器.

addKey(String, DataSourceConnection) - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.HashCacheConnectionKey

新增缓存

addNode(Integer, Connection) - 类 中的方法com.dtstack.dtcenter.loader.cache.connection.DataSourceConnection

新增数据源节点

addSort(SolrQueryDTO.SortClause) - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

排序

addURL(URL) - 类 中的方法com.dtstack.dtcenter.loader.DtClassLoader

Aggregator - com.dtstack.dtcenter.loader.dto.tsdb中的枚举

聚合器类型

aggregator(String) - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

alterTableParams(ISourceDTO, String, Map<String, String>) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITable

修改表参数

alterTableParams(ISourceDTO, String, Map<String, String>) - 类 中的方法com.dtstack.dtcenter.loader.client.table.TableClientProxy

asc(String) - 类 中的静态方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO.SortClause

AssertUtils - com.dtstack.dtcenter.loader.utils中的类

断言工具类

AssertUtils() - 类 的构造器com.dtstack.dtcenter.loader.utils.AssertUtils

authParams - 类 中的变量com.dtstack.dtcenter.loader.dto.source.WebSocketSourceDTO

鉴权参数

AwsS3SourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

aws s3 sourceDTO

AwsS3SourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.AwsS3SourceDTO

B

BigDecimalComparator - com.dtstack.dtcenter.loader.dto.comparator中的类

BigDecimalComparator(BigDecimal) - 类 的构造器com.dtstack.dtcenter.loader.dto.comparator.BigDecimalComparator

BinaryComparator - com.dtstack.dtcenter.loader.dto.comparator中的类

-

BinaryComparator(byte[]) - 类 的构造器com.dtstack.dtcenter.loader.dto.comparator.BinaryComparator

Constructor

BinaryPrefixComparator - com.dtstack.dtcenter.loader.dto.comparator中的类

BinaryPrefixComparator(byte[]) - 类 的构造器com.dtstack.dtcenter.loader.dto.comparator.BinaryPrefixComparator

Constructor

BitComparator - com.dtstack.dtcenter.loader.dto.comparator中的类

-

BitComparator(byte[], BitComparator.BitwiseOp) - 类 的构造器com.dtstack.dtcenter.loader.dto.comparator.BitComparator

Constructor

BitComparator.BitwiseOp - com.dtstack.dtcenter.loader.dto.comparator中的枚举

bitOperator - 类 中的变量com.dtstack.dtcenter.loader.dto.comparator.BitComparator

boolValue() - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.KeyValue

build() - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

build(boolean) - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

ByteArrayComparable - com.dtstack.dtcenter.loader.dto.comparator中的类

-

ByteArrayComparable(byte[]) - 类 的构造器com.dtstack.dtcenter.loader.dto.comparator.ByteArrayComparable

byteValue() - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.KeyValue

C

CacheConnectionHelper - com.dtstack.dtcenter.loader.cache.connection中的类

已过时。

CacheConnectionHelper() - 类 的构造器com.dtstack.dtcenter.loader.cache.connection.CacheConnectionHelper

已过时。

Callback<E> - com.dtstack.dtcenter.loader.functions中的接口

callbackAndReset(ClassLoaderCallBack<M>, ClassLoader) - 类 中的静态方法com.dtstack.dtcenter.loader.ClassLoaderCallBackMethod

charValue() - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.KeyValue

checkAndDelete(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

checkAndDelete(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

文件检测并删除

checkContainClassLoader(String) - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientFactory

校验是否存在

checkPoint(TsdbPoint) - 类 中的静态方法com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

ClassLoaderCallBack<T> - com.dtstack.dtcenter.loader中的接口

ClassLoaderCallBackMethod - com.dtstack.dtcenter.loader中的类

ClassLoaderCallBackMethod() - 类 的构造器com.dtstack.dtcenter.loader.ClassLoaderCallBackMethod

clearKey(String) - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.HashCacheConnectionKey

clearKey(String, Integer, Boolean) - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.HashCacheConnectionKey

ClickHouseSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

ClickHouseSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.ClickHouseSourceDTO

ClientAccessException - com.dtstack.dtcenter.loader.exception中的异常错误

ClientAccessException(Throwable) - 异常错误 的构造器com.dtstack.dtcenter.loader.exception.ClientAccessException

ClientCache - com.dtstack.dtcenter.loader.client中的类

ClientCache() - 类 的构造器com.dtstack.dtcenter.loader.client.ClientCache

ClientFactory - com.dtstack.dtcenter.loader.client中的类

ClientFactory() - 类 的构造器com.dtstack.dtcenter.loader.client.ClientFactory

close() - 类 中的方法com.dtstack.dtcenter.loader.cache.connection.DataSourceCacheNode

关闭数据库连接

close() - 类 中的方法com.dtstack.dtcenter.loader.cache.connection.DataSourceConnection

关闭之前存在的数据库连接

close(Integer) - 类 中的方法com.dtstack.dtcenter.loader.cache.connection.DataSourceConnection

close() - 类 中的方法com.dtstack.dtcenter.loader.downloader.DownloaderProxy

close() - 接口 中的方法com.dtstack.dtcenter.loader.IDownloader

是否关闭

closeCacheConnection() - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.CacheConnectionHelper

已过时。

closeCacheConnection(String) - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.CacheConnectionHelper

已过时。

关闭特定 KEY 的缓存连接

closeDBResources(ResultSet, Statement, Connection) - 类 中的静态方法com.dtstack.dtcenter.loader.utils.DBUtil

关闭数据库资源信息

Column - com.dtstack.dtcenter.loader.dto中的类

Column(String, Integer) - 类 的构造器com.dtstack.dtcenter.loader.dto.Column

Column() - 类 的构造器com.dtstack.dtcenter.loader.dto.Column

ColumnMetaDTO - com.dtstack.dtcenter.loader.dto中的类

ColumnMetaDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.ColumnMetaDTO

com.dtstack.dtcenter.loader - 程序包 com.dtstack.dtcenter.loader

com.dtstack.dtcenter.loader.cache.connection - 程序包 com.dtstack.dtcenter.loader.cache.connection

com.dtstack.dtcenter.loader.cache.pool.config - 程序包 com.dtstack.dtcenter.loader.cache.pool.config

com.dtstack.dtcenter.loader.cache.pool.manager - 程序包 com.dtstack.dtcenter.loader.cache.pool.manager

com.dtstack.dtcenter.loader.client - 程序包 com.dtstack.dtcenter.loader.client

com.dtstack.dtcenter.loader.client.hbase - 程序包 com.dtstack.dtcenter.loader.client.hbase

com.dtstack.dtcenter.loader.client.hdfs - 程序包 com.dtstack.dtcenter.loader.client.hdfs

com.dtstack.dtcenter.loader.client.kerberos - 程序包 com.dtstack.dtcenter.loader.client.kerberos

com.dtstack.dtcenter.loader.client.mq - 程序包 com.dtstack.dtcenter.loader.client.mq

com.dtstack.dtcenter.loader.client.restful - 程序包 com.dtstack.dtcenter.loader.client.restful

com.dtstack.dtcenter.loader.client.sql - 程序包 com.dtstack.dtcenter.loader.client.sql

com.dtstack.dtcenter.loader.client.table - 程序包 com.dtstack.dtcenter.loader.client.table

com.dtstack.dtcenter.loader.client.tsdb - 程序包 com.dtstack.dtcenter.loader.client.tsdb

com.dtstack.dtcenter.loader.downloader - 程序包 com.dtstack.dtcenter.loader.downloader

com.dtstack.dtcenter.loader.dto - 程序包 com.dtstack.dtcenter.loader.dto

com.dtstack.dtcenter.loader.dto.comparator - 程序包 com.dtstack.dtcenter.loader.dto.comparator

com.dtstack.dtcenter.loader.dto.contant - 程序包 com.dtstack.dtcenter.loader.dto.contant

com.dtstack.dtcenter.loader.dto.filter - 程序包 com.dtstack.dtcenter.loader.dto.filter

com.dtstack.dtcenter.loader.dto.restful - 程序包 com.dtstack.dtcenter.loader.dto.restful

com.dtstack.dtcenter.loader.dto.source - 程序包 com.dtstack.dtcenter.loader.dto.source

com.dtstack.dtcenter.loader.dto.tsdb - 程序包 com.dtstack.dtcenter.loader.dto.tsdb

com.dtstack.dtcenter.loader.enums - 程序包 com.dtstack.dtcenter.loader.enums

com.dtstack.dtcenter.loader.exception - 程序包 com.dtstack.dtcenter.loader.exception

com.dtstack.dtcenter.loader.factory - 程序包 com.dtstack.dtcenter.loader.factory

com.dtstack.dtcenter.loader.functions - 程序包 com.dtstack.dtcenter.loader.functions

com.dtstack.dtcenter.loader.kerberos - 程序包 com.dtstack.dtcenter.loader.kerberos

com.dtstack.dtcenter.loader.source - 程序包 com.dtstack.dtcenter.loader.source

com.dtstack.dtcenter.loader.utils - 程序包 com.dtstack.dtcenter.loader.utils

CommandType - com.dtstack.dtcenter.loader.enums中的枚举

Comparator - com.dtstack.dtcenter.loader.enums中的枚举

-

CompareOp - com.dtstack.dtcenter.loader.enums中的枚举

类作用：hbase过滤器的操作符

configure() - 类 中的方法com.dtstack.dtcenter.loader.downloader.DownloaderProxy

configure() - 接口 中的方法com.dtstack.dtcenter.loader.IDownloader

配置下载器

ConnectionClearStatus - com.dtstack.dtcenter.loader.enums中的枚举

consumeData(ISourceDTO, String, Integer, String, Long, Integer) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

从kafka 中消费数据

consumeData(ISourceDTO, String, Integer, String, Long, Integer) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

copyDirector(ISourceDTO, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

copyDirector(ISourceDTO, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

复制文件夹

copyFile(ISourceDTO, String, String, boolean) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

copyFile(ISourceDTO, String, String, boolean) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

复制文件

copyFromLocal(ISourceDTO, String, String, boolean) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

copyFromLocal(ISourceDTO, String, String, boolean) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

从本地copy到hdfs

copyToLocal(ISourceDTO, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

copyToLocal(ISourceDTO, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

从hdfs copy文件到本地

create(String, SolrQueryDTO.ORDER) - 类 中的静态方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO.SortClause

create(String, String) - 类 中的静态方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO.SortClause

createDatabase(ISourceDTO, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

创建数据库

createDatabase(ISourceDTO, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

createDir(ISourceDTO, String, Short) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

createDir(ISourceDTO, String, Short) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

创建 HDFS 路径

createHbaseTable(ISourceDTO, String, String[]) - 类 中的方法com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

createHbaseTable(ISourceDTO, String, String, String[]) - 类 中的方法com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

createHbaseTable(ISourceDTO, String, String[]) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHbase

hbase创建表

createHbaseTable(ISourceDTO, String, String, String[]) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHbase

hbase创建表，指定namespace

createPluginClass(String) - 类 中的静态方法com.dtstack.dtcenter.loader.client.hbase.HbaseClientFactory

createPluginClass(String) - 类 中的静态方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileClientFactory

createPluginClass(String) - 类 中的静态方法com.dtstack.dtcenter.loader.client.kerberos.KerberosClientFactory

createPluginClass(String) - 类 中的静态方法com.dtstack.dtcenter.loader.client.mq.KafkaClientFactory

createPluginClass(String) - 类 中的静态方法com.dtstack.dtcenter.loader.client.restful.RestfulClientFactory

createPluginClass(String) - 类 中的静态方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientFactory

createPluginClass(String) - 类 中的静态方法com.dtstack.dtcenter.loader.client.table.TableClientFactory

createPluginClass(String) - 类 中的静态方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientFactory

createTopic(ISourceDTO, KafkaTopicDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

创建 Topic

createTopic(ISourceDTO, KafkaTopicDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

D

DataBaseType - com.dtstack.dtcenter.loader.source中的枚举

已过时。

DataSourceCacheNode - com.dtstack.dtcenter.loader.cache.connection中的类

DataSourceCacheNode() - 类 的构造器com.dtstack.dtcenter.loader.cache.connection.DataSourceCacheNode

DataSourceClientCache - com.dtstack.dtcenter.loader.client.sql中的类

已过时。

DataSourceClientCache() - 类 的构造器com.dtstack.dtcenter.loader.client.sql.DataSourceClientCache

已过时。

DataSourceClientFactory - com.dtstack.dtcenter.loader.client.sql中的类

DataSourceClientFactory() - 类 的构造器com.dtstack.dtcenter.loader.client.sql.DataSourceClientFactory

DataSourceClientProxy<T> - com.dtstack.dtcenter.loader.client.sql中的类

DataSourceClientProxy(IClient) - 类 的构造器com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

DataSourceConnection - com.dtstack.dtcenter.loader.cache.connection中的类

DataSourceConnection() - 类 的构造器com.dtstack.dtcenter.loader.cache.connection.DataSourceConnection

DataSourceType - com.dtstack.dtcenter.loader.source中的枚举

Db2SourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

Db2SourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.Db2SourceDTO

DBUtil - com.dtstack.dtcenter.loader.utils中的类

DBUtil() - 类 的构造器com.dtstack.dtcenter.loader.utils.DBUtil

DEBUG_QUERY - 接口 中的静态变量com.dtstack.dtcenter.loader.dto.contant.SolrCommonParams

whether to include debug data for all components pieces, including doing explains

delete(ISourceDTO, String, boolean) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

delete(ISourceDTO, String, boolean) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

直接删除目标路径文件

delete(RestfulSourceDTO, String, Map<String, String>, Map<String, String>) - 接口 中的方法com.dtstack.dtcenter.loader.client.IRestful

delete 请求

delete(RestfulSourceDTO, String, Map<String, String>, Map<String, String>) - 类 中的方法com.dtstack.dtcenter.loader.client.restful.RestfulClientProxy

deleteByRowKey(ISourceDTO, String, String, String, List<String>) - 类 中的方法com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

deleteByRowKey(ISourceDTO, String, String, String, List<String>) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHbase

hbase 根据rowKey删除数据

deleteData(ISourceDTO, String, long, long) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITsdb

根据 metric 、开始时间、结束时间删除数据

deleteData(ISourceDTO, String, Map<String, String>, long, long) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITsdb

根据 metric 、tags、开始时间、结束时间删除数据

deleteData(ISourceDTO, String, List<String>, long, long) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITsdb

根据 metric 、字段、开始时间、结束时间删除数据

deleteData(ISourceDTO, String, Map<String, String>, List<String>, long, long) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITsdb

根据 metric 、tags、字段、开始时间、结束时间删除数据

deleteData(ISourceDTO, String, long, long) - 类 中的方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

deleteData(ISourceDTO, String, Map<String, String>, long, long) - 类 中的方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

deleteData(ISourceDTO, String, List<String>, long, long) - 类 中的方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

deleteData(ISourceDTO, String, Map<String, String>, List<String>, long, long) - 类 中的方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

deleteFiles(ISourceDTO, List<String>) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

deleteFiles(ISourceDTO, List<String>) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

删除文件

deleteHbaseTable(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

deleteHbaseTable(ISourceDTO, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

deleteHbaseTable(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHbase

hbase 删除表

deleteHbaseTable(ISourceDTO, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHbase

hbase 删除表

deleteMeta(ISourceDTO, String, Map<String, String>) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITsdb

根据 metric 、tags删除数据

deleteMeta(ISourceDTO, String, Map<String, String>, List<String>) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITsdb

根据 metric 、tags、fields删除数据

deleteMeta(ISourceDTO, String, Map<String, String>, boolean, boolean) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITsdb

根据 metric 、tags 删除数据

deleteMeta(ISourceDTO, String, List<String>, Map<String, String>, boolean, boolean) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITsdb

根据 metric 、tags 删除数据

deleteMeta(ISourceDTO, String, Map<String, String>) - 类 中的方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

deleteMeta(ISourceDTO, String, Map<String, String>, List<String>) - 类 中的方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

deleteMeta(ISourceDTO, String, Map<String, String>, boolean, boolean) - 类 中的方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

deleteMeta(ISourceDTO, String, List<String>, Map<String, String>, boolean, boolean) - 类 中的方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

DeltaOptions - com.dtstack.dtcenter.loader.dto.tsdb中的类

聚合器类型

DeltaOptions() - 类 的构造器com.dtstack.dtcenter.loader.dto.tsdb.DeltaOptions

desc(String) - 类 中的静态方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO.SortClause

DF - 接口 中的静态变量com.dtstack.dtcenter.loader.dto.contant.SolrCommonParams

default query field

DmSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

DmSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.DmSourceDTO

DorisSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

DorisSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.DorisSourceDTO

doubleValue() - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.KeyValue

DownloaderProxy - com.dtstack.dtcenter.loader.downloader中的类

IDownloader代理类 若不加此代理类，由于获取到IDownloader后，当前线程的ContextClassLoader会被设置成旧的ClassLoader 这样在执行IDownloader中方法的时候如果方法中有对线程ContextClassLoader进行获取操作则会导致ClassLoader不一致

DownloaderProxy(IDownloader) - 类 的构造器com.dtstack.dtcenter.loader.downloader.DownloaderProxy

downloadFileFromHdfs(ISourceDTO, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

downloadFileFromHdfs(ISourceDTO, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

从 HDFS 上下载文件或文件夹到本地

dropTable(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITable

删除表，成功返回true，失败返回false

dropTable(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.table.TableClientProxy

DtClassLoader - com.dtstack.dtcenter.loader中的类

DtClassLoader(URL[], ClassLoader) - 类 的构造器com.dtstack.dtcenter.loader.DtClassLoader

DtClassLoader(URL[]) - 类 的构造器com.dtstack.dtcenter.loader.DtClassLoader

DtClassLoader(URL[], ClassLoader, URLStreamHandlerFactory) - 类 的构造器com.dtstack.dtcenter.loader.DtClassLoader

Constructs a new URLClassLoader for the given URLs parent 将他的父亲设置为当前这个 ClassLoader factory URL流协议处理程序定义工厂

DtLoaderException - com.dtstack.dtcenter.loader.exception中的异常错误

DtLoaderException(String) - 异常错误 的构造器com.dtstack.dtcenter.loader.exception.DtLoaderException

DtLoaderException(String, Throwable) - 异常错误 的构造器com.dtstack.dtcenter.loader.exception.DtLoaderException

DtThreadFactory - com.dtstack.dtcenter.loader.factory中的类

已过时。

DtThreadFactory(String) - 类 的构造器com.dtstack.dtcenter.loader.factory.DtThreadFactory

已过时。

E

EMQSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

EMQSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.EMQSourceDTO

ES7SourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

ES7SourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.ES7SourceDTO

EsCommandType - com.dtstack.dtcenter.loader.enums中的枚举

ESSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

ESSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.ESSourceDTO

execute() - 接口 中的方法com.dtstack.dtcenter.loader.ClassLoaderCallBack

抽象执行类

executeQuery(ISourceDTO, HbaseQueryDTO, TimestampFilter) - 类 中的方法com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

executeQuery(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

执行查询

executeQuery(ISourceDTO, HbaseQueryDTO, TimestampFilter) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHbase

hbase 自定义查询

executeQuery(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITable

执行sql查询

executeQuery(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

executeQuery(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.table.TableClientProxy

executeQuery(Connection, String, Boolean) - 类 中的静态方法com.dtstack.dtcenter.loader.utils.DBUtil

根据 SQL 查询

executeQuery(Connection, String, Boolean, List<Object>, Integer) - 类 中的静态方法com.dtstack.dtcenter.loader.utils.DBUtil

根据 SQL 查询 - 预编译查询

executeSqlWithoutResultSet(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

执行查询，无需结果集

executeSqlWithoutResultSet(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITable

执行sql，不需要结果

executeSqlWithoutResultSet(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

executeSqlWithoutResultSet(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.table.TableClientProxy

executeSqlWithoutResultSet(Connection, String, Boolean) - 类 中的静态方法com.dtstack.dtcenter.loader.utils.DBUtil

执行查询，无需结果集

F

FileFormat - com.dtstack.dtcenter.loader.enums中的枚举

hdfsWriter支持的格式

fileMerge(ISourceDTO, String, String, FileFormat, Long, Long) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

fileMerge(ISourceDTO, String, String, FileFormat, Long, Long) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

合并小文件

FileStatus - com.dtstack.dtcenter.loader.dto中的类

FileStatus() - 类 的构造器com.dtstack.dtcenter.loader.dto.FileStatus

Filter - com.dtstack.dtcenter.loader.dto.filter中的类

Filter() - 类 的构造器com.dtstack.dtcenter.loader.dto.filter.Filter

Filter - com.dtstack.dtcenter.loader.dto.tsdb中的类

过滤器

Filter() - 类 的构造器com.dtstack.dtcenter.loader.dto.tsdb.Filter

FilterList - com.dtstack.dtcenter.loader.dto.filter中的类

FilterList(List<Filter>) - 类 的构造器com.dtstack.dtcenter.loader.dto.filter.FilterList

过滤器类型构造 Filter，默认类型为 MUST_PASS_ALL is assumed.

FilterList(FilterList.Operator) - 类 的构造器com.dtstack.dtcenter.loader.dto.filter.FilterList

过滤器类型构造.

FilterList(FilterList.Operator, List<Filter>) - 类 的构造器com.dtstack.dtcenter.loader.dto.filter.FilterList

operator 和 过滤器构造，支持集合.

FilterList(FilterList.Operator, Filter...) - 类 的构造器com.dtstack.dtcenter.loader.dto.filter.FilterList

operator 和 过滤器构造，支持可变参数.

FilterList.Operator - com.dtstack.dtcenter.loader.dto.filter中的枚举

FilterType - com.dtstack.dtcenter.loader.dto.tsdb中的枚举

过滤器类型

findResources(String) - 类 中的方法com.dtstack.dtcenter.loader.DtClassLoader

FL - 接口 中的静态变量com.dtstack.dtcenter.loader.dto.contant.SolrCommonParams

query and init param for field list

floatValue() - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.KeyValue

FQ - 接口 中的静态变量com.dtstack.dtcenter.loader.dto.contant.SolrCommonParams

Lucene query string(s) for filtering the results without affecting scoring

FtpSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

FtpSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.FtpSourceDTO

G

GBaseSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

GBaseSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.GBaseSourceDTO

get(RestfulSourceDTO, Map<String, String>, Map<String, String>, Map<String, String>) - 接口 中的方法com.dtstack.dtcenter.loader.client.IRestful

get 请求

get(RestfulSourceDTO, Map<String, String>, Map<String, String>, Map<String, String>) - 类 中的方法com.dtstack.dtcenter.loader.client.restful.RestfulClientProxy

getAlias() - 类 中的方法com.dtstack.dtcenter.loader.dto.Column

getAllBrokersAddress(ISourceDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

获取所有 Brokers 的地址

getAllBrokersAddress(ISourceDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

getAllDatabases(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取所有的 DB

getAllDatabases(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getAllPartitions(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

已过时。

getAllPartitions(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

getBigDecimal() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.BigDecimalComparator

getBitOperator() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.BitComparator

getCatalogs(ISourceDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取数据源/数据库目录列表，目前presto使用，后续pgSql等可以实现该方法用于获取所有库

getCatalogs(ISourceDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getClassLoader(String) - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientFactory

获取类加载器

getClient(Integer) - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientCache

获取 Sql Client 客户端

getClient(String) - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientCache

已过时。

getColumnClassInfo(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

返回字段 Java 类的标准名称 字段名若不填则默认全部

getColumnClassInfo(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getColumnFamily() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.SingleColumnValueFilter

getColumnList(ISourceDTO, SqlQueryDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

getColumnList(ISourceDTO, SqlQueryDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

获取hdfs上存储文件的字段信息

getColumnMetaData(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取表字段属性 字段名若不填则默认全部, 是否过滤分区字段 不填默认不过滤

getColumnMetaData(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getColumnMetaDataWithSql(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

根据自定义sql获取表字段属性

getColumnMetaDataWithSql(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getColumnQualifier() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.SingleColumnValueFilter

getColumns(List<String>) - 类 中的静态方法com.dtstack.dtcenter.loader.dto.Column

getComment() - 类 中的方法com.dtstack.dtcenter.loader.dto.Column

getComparator() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.RowFilter

getComparator() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.SingleColumnValueFilter

getComparator() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.TimestampFilter

getComparatorType() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.BigDecimalComparator

getComparatorType() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.BinaryComparator

getComparatorType() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.BinaryPrefixComparator

getComparatorType() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.BitComparator

getComparatorType() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.ByteArrayComparable

getComparatorType() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.LongComparator

getComparatorType() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.NullComparator

getComparatorType() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.RegexStringComparator

getComparatorType() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.SubstringComparator

getCompareOp() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.RowFilter

getCompareOp() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.SingleColumnValueFilter

getCompareOp() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.TimestampFilter

getCon(ISourceDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取 连接

getCon(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取 连接

getCon(ISourceDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITable

rdbms数据库获取连接唯一入口，对抛出异常进行统一处理

getCon(ISourceDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getCon(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getCon(ISourceDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.table.TableClientProxy

getConnection(Integer) - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.CacheConnectionHelper

已过时。

获取 缓存连接

getConnection(String, Integer) - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.CacheConnectionHelper

已过时。

getConnection(Integer, Callback<Connection>) - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.CacheConnectionHelper

已过时。

getConnection(String, Integer, Callback<Connection>) - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.CacheConnectionHelper

已过时。

getConnection(Integer) - 类 中的方法com.dtstack.dtcenter.loader.cache.connection.DataSourceConnection

根据数据源类型获取连接

getConnection(ISourceDTO) - 接口 中的方法com.dtstack.dtcenter.loader.cache.pool.manager.Manager

获取连接

getConnection() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.AwsS3SourceDTO

getConnection() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.EMQSourceDTO

getConnection() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.FtpSourceDTO

getConnection() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.HdfsSourceDTO

getConnection() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.InfluxDBSourceDTO

getConnection() - 接口 中的方法com.dtstack.dtcenter.loader.dto.source.ISourceDTO

获取连接信息

getConnection() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.KafkaSourceDTO

getConnection() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.KylinRestfulSourceDTO

getConnection() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.MongoSourceDTO

getConnection() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.OpenTSDBSourceDTO

getConnection() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.RedisSourceDTO

getConnection() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.RestfulSourceDTO

getConnection() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.S3SourceDTO

getConnection() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.SocketSourceDTO

getConnection() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.WebSocketSourceDTO

getConSize() - 类 中的方法com.dtstack.dtcenter.loader.cache.connection.DataSourceConnection

getContainers() - 类 中的方法com.dtstack.dtcenter.loader.downloader.DownloaderProxy

getContainers() - 接口 中的方法com.dtstack.dtcenter.loader.IDownloader

获取容器

getContentSummary(ISourceDTO, List<String>) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

getContentSummary(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

getContentSummary(ISourceDTO, List<String>) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

批量统计文件夹内容摘要，包括文件的数量，文件夹的数量，文件变动时间，以及这个文件夹的占用存储等内容

getContentSummary(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

统计文件夹内容摘要，包括文件的数量，文件夹的数量，文件变动时间，以及这个文件夹的占用存储等内容

getCreateTableSql(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取建表语句

getCreateTableSql(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getCurrentDatabase(ISourceDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取当前使用的数据库

getCurrentDatabase(ISourceDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getDirSize(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

getDirSize(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

获取路径文件大小

getDownloader(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取对应的downloader

getDownloader(ISourceDTO, String, Integer) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

根据执行 sql 下载数据

getDownloader(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getDownloader(ISourceDTO, String, Integer) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getDownloaderByFormat(ISourceDTO, String, List<String>, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

getDownloaderByFormat(ISourceDTO, String, List<String>, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

根据文件格式获取对应的downlaoder

getDriverClassName() - 枚举 中的方法com.dtstack.dtcenter.loader.source.DataBaseType

已过时。

getEngineType() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.RegexStringComparator

getEnum(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.tsdb.Aggregator

getEnum(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.Granularity

getExpr() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.RegexStringComparator

getFileDownloader(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

getFileDownloader(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

文件下载器

getFileName() - 类 中的方法com.dtstack.dtcenter.loader.downloader.DownloaderProxy

getFileName() - 接口 中的方法com.dtstack.dtcenter.loader.IDownloader

获取文件名

getFilterPartitionColumns() - 类 中的方法com.dtstack.dtcenter.loader.dto.SqlQueryDTO

getFilters() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.FilterList

获取过滤器列表.

getFilterType() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.Filter

getFilterType() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.FilterList

getFilterType() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.PageFilter

getFilterType() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.RowFilter

getFilterType() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.SingleColumnValueFilter

getFilterType() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.TimestampFilter

getFlags() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.RegexStringComparator

getFlinkColumnMetaData(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取flinkSql字段名称

getFlinkColumnMetaData(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getGroupInfoByGroupId(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

获取 kafka 消费者组详细信息

getGroupInfoByGroupId(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

getGroupInfoByGroupIdAndTopic(ISourceDTO, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

获取 kafka 指定topic下指定消费者组详细信息

getGroupInfoByGroupIdAndTopic(ISourceDTO, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

getGroupInfoByTopic(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

获取 kafka 指定topic 下消费者组详细信息

getGroupInfoByTopic(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

getHbase(Integer) - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientCache

获取 hbase 服务客户端

getHdfs(Integer) - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientCache

获取 HDFS 文件客户端

getHdfs(String) - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientCache

已过时。

getIndex() - 类 中的方法com.dtstack.dtcenter.loader.dto.Column

getItem() - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO.SortClause

getKafka(Integer) - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientCache

获取 KAFKA 客户端

getKafka(String) - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientCache

已过时。

getKafkaS() - 枚举 中的静态方法com.dtstack.dtcenter.loader.source.DataSourceType

获取所有的 kafka 相关数据源

getKerberos(Integer) - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientCache

获取 Kerberos 服务客户端

getLogDownloader(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

getLogDownloader(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

日志下载器

getLongValue() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.LongComparator

getMetaInfo() - 类 中的方法com.dtstack.dtcenter.loader.downloader.DownloaderProxy

getMetaInfo() - 接口 中的方法com.dtstack.dtcenter.loader.IDownloader

获取元数据信息

getMinimumIdle() - 类 中的方法com.dtstack.dtcenter.loader.cache.pool.config.PoolConfig

getName() - 类 中的方法com.dtstack.dtcenter.loader.dto.Column

getName() - 枚举 中的方法com.dtstack.dtcenter.loader.dto.tsdb.Aggregator

getName() - 枚举 中的方法com.dtstack.dtcenter.loader.dto.tsdb.Suggest

getName() - 枚举 中的方法com.dtstack.dtcenter.loader.enums.Granularity

getName() - 枚举 中的方法com.dtstack.dtcenter.loader.source.DataSourceType

getOffset(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

获取特定 Topic 所有分区的偏移量

getOffset(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

getOperator() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.FilterList

获取过滤器类型 OR ｜ ADN.

getOrder() - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO.SortClause

getOrder() - 枚举 中的方法com.dtstack.dtcenter.loader.source.DataSourceType

getOrderDps() - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.QueryResult

getOrderDps(boolean) - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.QueryResult

获取排序后的数据

getPageSize() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.PageFilter

getPartitionColumn(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取分区字段

getPartitionColumn(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getPassword() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.AwsS3SourceDTO

getPassword() - 接口 中的方法com.dtstack.dtcenter.loader.dto.source.ISourceDTO

获取密码

getPassword() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.KylinRestfulSourceDTO

getPassword() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.OpenTSDBSourceDTO

getPassword() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.RestfulSourceDTO

getPluginName() - 枚举 中的方法com.dtstack.dtcenter.loader.source.DataSourceType

getPreview(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取预览数据

getPreview(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

已过时。

since 1.4.0 in favor of IKafka.getPreview(ISourceDTO source, SqlQueryDTO queryDTO, String prevMode)

getPreview(ISourceDTO, SqlQueryDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

获取预览数据

getPreview(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

getPreview(ISourceDTO, SqlQueryDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

getPreview(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getPreviewNum() - 类 中的方法com.dtstack.dtcenter.loader.dto.SqlQueryDTO

getPrincipals(String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKerberos

从 JDBC URL 中获取 Principal

getPrincipals(Map<String, Object>) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKerberos

从 Kerberos 配置文件中获取 Principal

getPrincipals(String) - 类 中的方法com.dtstack.dtcenter.loader.client.kerberos.KerberosProxy

getPrincipals(Map<String, Object>) - 类 中的方法com.dtstack.dtcenter.loader.client.kerberos.KerberosProxy

getQueryParamMap() - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

getRDBMS() - 枚举 中的静态方法com.dtstack.dtcenter.loader.source.DataSourceType

获取所有的关系数据库

getRedisModel(int) - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.RedisMode

getResource(String) - 类 中的方法com.dtstack.dtcenter.loader.DtClassLoader

getResources(String) - 类 中的方法com.dtstack.dtcenter.loader.DtClassLoader

FIXME 需要测试

getRestful(Integer) - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientCache

获取 restful Client 客户端

getRootDatabases(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取所有的db，此方法目的为获取所有的 database，为了解决一些遗留问题。

getRootDatabases(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getRow(ISourceDTO, String, String, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

getRow(ISourceDTO, String, String, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHbase

hbase根据rowKey获取数据

getSessionKey() - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.CacheConnectionHelper

已过时。

获取缓存唯一键

getSessionKey() - 类 中的方法com.dtstack.dtcenter.loader.cache.connection.DataSourceConnection

获取 连接主键

getSimilarSessionKey(String) - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.HashCacheConnectionKey

getSourceCacheNode(Integer) - 类 中的方法com.dtstack.dtcenter.loader.cache.connection.DataSourceConnection

获取资源节点

getSourceConnection(String) - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.HashCacheConnectionKey

获取缓存连接信息

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.AwsS3SourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.ClickHouseSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.Db2SourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.DmSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.DorisSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.EMQSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.ES7SourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.ESSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.FtpSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.GBaseSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.Greenplum6SourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.HbaseSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.HdfsSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.Hive1SourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.Hive3SourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.HiveSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.ImpalaSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.InceptorSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.InfluxDBSourceDTO

getSourceType() - 接口 中的方法com.dtstack.dtcenter.loader.dto.source.ISourceDTO

获取数据源类型

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.KafkaSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.KingbaseSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.KuduSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.KylinRestfulSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.KylinSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.LibraSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.MongoSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.Mysql5SourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.Mysql8SourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.OceanBaseSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.OdpsSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.OpenTSDBSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.OracleSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.Phoenix5SourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.PhoenixSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.PostgresqlSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.PrestoSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.RedisSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.RestfulSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.S3SourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.SolrSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.SparkSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.Sqlserver2017SourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.SqlserverSourceDTO

getSourceType() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.VerticaSourceDTO

getSourceType(int) - 枚举 中的静态方法com.dtstack.dtcenter.loader.source.DataSourceType

根据值获取数据源类型

getStatus(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

getStatus(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

获取 HDFS 对应地址文件信息

getSubstr() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.SubstringComparator

getTable(Integer) - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientCache

获取 table Client 客户端

getTable(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取表信息

getTable(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getTable() - 类 中的方法com.dtstack.dtcenter.loader.dto.Column

getTableList(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

返回所有的表字段名称 是否视图表，默认不过滤

getTableList(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getTableListBySchema(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

根据schema/db获取表

getTableListBySchema(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getTableMetaComment(ISourceDTO, SqlQueryDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取表注释

getTableMetaComment(ISourceDTO, SqlQueryDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getTableSize(ISourceDTO, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITable

获取表占用存储

getTableSize(ISourceDTO, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.table.TableClientProxy

getTableTypes(SqlQueryDTO) - 类 中的静态方法com.dtstack.dtcenter.loader.utils.DBUtil

重置表类型 DatabaseMetaData.getTableTypes()

getTestSql() - 枚举 中的方法com.dtstack.dtcenter.loader.source.DataBaseType

已过时。

getTimeoutStamp() - 类 中的方法com.dtstack.dtcenter.loader.cache.connection.DataSourceConnection

getTopicList(ISourceDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

获取 所有 Topic 信息

getTopicList(ISourceDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

getTopicPartitions(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

获取kafka指定topic下的分区信息

getTopicPartitions(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

getTsdb(Integer) - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientCache

获取 tsdb Client 客户端

getType() - 类 中的方法com.dtstack.dtcenter.loader.dto.Column

getType() - 枚举 中的方法com.dtstack.dtcenter.loader.enums.CommandType

getType() - 枚举 中的方法com.dtstack.dtcenter.loader.enums.EsCommandType

getTypeName() - 枚举 中的方法com.dtstack.dtcenter.loader.source.DataBaseType

已过时。

getUserDir() - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientCache

获取插件包文件夹路径

getUsername() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.AwsS3SourceDTO

getUsername() - 接口 中的方法com.dtstack.dtcenter.loader.dto.source.ISourceDTO

获取用户名

getUsername() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.KylinRestfulSourceDTO

getUsername() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.OpenTSDBSourceDTO

getUsername() - 类 中的方法com.dtstack.dtcenter.loader.dto.source.RestfulSourceDTO

getVal() - 枚举 中的方法com.dtstack.dtcenter.loader.enums.Comparator

getVal() - 枚举 中的方法com.dtstack.dtcenter.loader.enums.FileFormat

getVal() - 枚举 中的方法com.dtstack.dtcenter.loader.enums.HbaseFilterType

getVal() - 枚举 中的方法com.dtstack.dtcenter.loader.source.DataSourceType

getValue() - 类 中的方法com.dtstack.dtcenter.loader.dto.comparator.ByteArrayComparable

getValue() - 枚举 中的方法com.dtstack.dtcenter.loader.enums.ConnectionClearStatus

getValue() - 枚举 中的方法com.dtstack.dtcenter.loader.enums.RedisMode

getVersion(ISourceDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

获取当前数据源的版本

getVersion(ISourceDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

getVersionInfo(ISourceDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITsdb

获取详细版本信息

getVersionInfo(ISourceDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

getView() - 类 中的方法com.dtstack.dtcenter.loader.dto.SqlQueryDTO

granularity(Granularity) - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

Granularity - com.dtstack.dtcenter.loader.enums中的枚举

TSDB 时间粒度

Greenplum6SourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

Greenplum6SourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.Greenplum6SourceDTO

H

HADOOP_SECURITY_AUTHORIZATION - 类 中的静态变量com.dtstack.dtcenter.loader.kerberos.HadoopConfTool

已过时。

Hadoop 开启 Kerberos 是否需要二次认证

HadoopConfTool - com.dtstack.dtcenter.loader.kerberos中的类

已过时。

HadoopConfTool() - 类 的构造器com.dtstack.dtcenter.loader.kerberos.HadoopConfTool

已过时。

HashCacheConnectionKey - com.dtstack.dtcenter.loader.cache.connection中的类

HashCacheConnectionKey() - 类 的构造器com.dtstack.dtcenter.loader.cache.connection.HashCacheConnectionKey

HBASE_MASTER_PRINCIPAL - 类 中的静态变量com.dtstack.dtcenter.loader.kerberos.HadoopConfTool

已过时。

Hbase master Principal 键

HBASE_REGION_PRINCIPAL - 类 中的静态变量com.dtstack.dtcenter.loader.kerberos.HadoopConfTool

已过时。

Hbase region Principal 键

HbaseClientFactory - com.dtstack.dtcenter.loader.client.hbase中的类

hbase客户端工厂

HbaseClientFactory() - 类 的构造器com.dtstack.dtcenter.loader.client.hbase.HbaseClientFactory

HbaseFilterType - com.dtstack.dtcenter.loader.enums中的枚举

-

HbaseProxy - com.dtstack.dtcenter.loader.client.hbase中的类

hbase客户端代理

HbaseProxy(IHbase) - 类 的构造器com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

HbaseQueryDTO - com.dtstack.dtcenter.loader.dto中的类

hbase queryDTO

HbaseQueryDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.HbaseQueryDTO

HbaseQueryDTO.ColumnType - com.dtstack.dtcenter.loader.dto中的枚举

HbaseSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

HbaseSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.HbaseSourceDTO

HDFSContentSummary - com.dtstack.dtcenter.loader.dto中的类

HDFS文件内容摘要 包括包括文件的数量，文件夹的数量，以及这个文件夹的大小等内容

HDFSContentSummary() - 类 的构造器com.dtstack.dtcenter.loader.dto.HDFSContentSummary

HdfsFileClientCache - com.dtstack.dtcenter.loader.client.hdfs中的类

已过时。

HdfsFileClientCache() - 类 的构造器com.dtstack.dtcenter.loader.client.hdfs.HdfsFileClientCache

已过时。

HdfsFileClientFactory - com.dtstack.dtcenter.loader.client.hdfs中的类

HdfsFileClientFactory() - 类 的构造器com.dtstack.dtcenter.loader.client.hdfs.HdfsFileClientFactory

HdfsFileProxy - com.dtstack.dtcenter.loader.client.hdfs中的类

HdfsFileProxy(IHdfsFile) - 类 的构造器com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

HDFSImportColumn - com.dtstack.dtcenter.loader.dto中的类

hdfs导入类

HDFSImportColumn() - 类 的构造器com.dtstack.dtcenter.loader.dto.HDFSImportColumn

HdfsSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

HdfsSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.HdfsSourceDTO

HdfsWriterDTO - com.dtstack.dtcenter.loader.dto中的类

写入hdfs的参数列表

HdfsWriterDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.HdfsWriterDTO

Hive1SourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

Hive1SourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.Hive1SourceDTO

Hive3SourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

Hive3SourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.Hive3SourceDTO

HiveSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

HiveSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.HiveSourceDTO

I

IClient<T> - com.dtstack.dtcenter.loader.client中的接口

IDownloader - com.dtstack.dtcenter.loader中的接口

IHbase - com.dtstack.dtcenter.loader.client中的接口

hbase客户端接口

IHdfsFile - com.dtstack.dtcenter.loader.client中的接口

IKafka<T> - com.dtstack.dtcenter.loader.client中的接口

IKerberos - com.dtstack.dtcenter.loader.client中的接口

ImpalaSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

ImpalaSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.ImpalaSourceDTO

InceptorSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

inceptor 数据源信息

InceptorSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.InceptorSourceDTO

InfluxDBSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

influxDB 数据源连接信息

InfluxDBSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.InfluxDBSourceDTO

initSource(ISourceDTO) - 接口 中的方法com.dtstack.dtcenter.loader.cache.pool.manager.Manager

初始化数据源连接池

intValue() - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.KeyValue

IRestful - com.dtstack.dtcenter.loader.client中的接口

提供 Restful 相关操作方法

isCache - 类 中的变量com.dtstack.dtcenter.loader.dto.source.EMQSourceDTO

是否缓存

isCache - 类 中的变量com.dtstack.dtcenter.loader.dto.source.FtpSourceDTO

是否缓存

isCache - 类 中的变量com.dtstack.dtcenter.loader.dto.source.KafkaSourceDTO

是否缓存

isCache - 类 中的变量com.dtstack.dtcenter.loader.dto.source.RedisSourceDTO

是否缓存

isContainSessionKey(String) - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.HashCacheConnectionKey

判断是否存在

isDatabaseExists(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

判断数据库是否存在

isDatabaseExists(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

isDbExists(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

isDbExists(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHbase

判断namespace是否存在

isDirExist(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

isDirExist(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

路径目录是否存在

isFalse(boolean, String) - 类 中的静态方法com.dtstack.dtcenter.loader.utils.AssertUtils

isFileExist(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

isFileExist(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

路径文件是否存在

isFilterIfMissing() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.SingleColumnValueFilter

isLatestVersionOnly() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.SingleColumnValueFilter

isNull(Object, String) - 类 中的静态方法com.dtstack.dtcenter.loader.utils.AssertUtils

ISourceDTO - com.dtstack.dtcenter.loader.dto.source中的接口

isOverLength(String, Integer, String) - 类 中的静态方法com.dtstack.dtcenter.loader.utils.AssertUtils

isReversed() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.RowFilter

isReversed() - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.SingleColumnValueFilter

isStart() - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.CacheConnectionHelper

已过时。

判断是否开启缓存

isTableExistsInDatabase(ISourceDTO, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

判断该数据库中是否存在该表

isTableExistsInDatabase(ISourceDTO, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

isTrue(boolean, String) - 类 中的静态方法com.dtstack.dtcenter.loader.utils.AssertUtils

isView(ISourceDTO, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITable

已过时。

isView(ISourceDTO, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.table.TableClientProxy

ITable - com.dtstack.dtcenter.loader.client中的接口

提供表相关操作接口

ITsdb - com.dtstack.dtcenter.loader.client中的接口

提供 OpenTSDB 相关操作方法

K

KAFKA_KERBEROS_KEYTAB - 类 中的静态变量com.dtstack.dtcenter.loader.kerberos.HadoopConfTool

已过时。

Kafka kerberos keytab 键

KAFKA_KERBEROS_SERVICE_NAME - 类 中的静态变量com.dtstack.dtcenter.loader.kerberos.HadoopConfTool

已过时。

Kafka Principal 参数，也可选 Principal

KafkaClientCache - com.dtstack.dtcenter.loader.client.mq中的类

已过时。

KafkaClientCache() - 类 的构造器com.dtstack.dtcenter.loader.client.mq.KafkaClientCache

已过时。

KafkaClientFactory - com.dtstack.dtcenter.loader.client.mq中的类

KafkaClientFactory() - 类 的构造器com.dtstack.dtcenter.loader.client.mq.KafkaClientFactory

KafkaClientProxy<T> - com.dtstack.dtcenter.loader.client.mq中的类

KafkaClientProxy(IKafka) - 类 的构造器com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

KafkaConsumerDTO - com.dtstack.dtcenter.loader.dto中的类

kafka 消费者组相关参数

KafkaConsumerDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.KafkaConsumerDTO

KafkaOffsetDTO - com.dtstack.dtcenter.loader.dto中的类

KafkaOffsetDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.KafkaOffsetDTO

KafkaPartitionDTO - com.dtstack.dtcenter.loader.dto中的类

kafka分区信息传输类

KafkaPartitionDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.KafkaPartitionDTO

KafkaPartitionDTO.Node - com.dtstack.dtcenter.loader.dto中的类

KafkaSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

KafkaSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.KafkaSourceDTO

KafkaTopicDTO - com.dtstack.dtcenter.loader.dto中的类

KafkaTopicDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.KafkaTopicDTO

KerberosClientFactory - com.dtstack.dtcenter.loader.client.kerberos中的类

KerberosClientFactory() - 类 的构造器com.dtstack.dtcenter.loader.client.kerberos.KerberosClientFactory

KerberosProxy - com.dtstack.dtcenter.loader.client.kerberos中的类

KerberosProxy(IKerberos) - 类 的构造器com.dtstack.dtcenter.loader.client.kerberos.KerberosProxy

KEY_JAVA_SECURITY_KRB5_CONF - 类 中的静态变量com.dtstack.dtcenter.loader.kerberos.HadoopConfTool

已过时。

krb5 系统属性键

KeyValue - com.dtstack.dtcenter.loader.dto.tsdb中的类

K、V 对

KeyValue() - 类 的构造器com.dtstack.dtcenter.loader.dto.tsdb.KeyValue

KingbaseSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

kingbase 数据源信息

KingbaseSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.KingbaseSourceDTO

KuduSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

KuduSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.KuduSourceDTO

KylinRestfulSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

KylinRestfulSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.KylinRestfulSourceDTO

KylinSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

KylinSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.KylinSourceDTO

L

LibraSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

LibraSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.LibraSourceDTO

listAllFilePath(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

listAllFilePath(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

获取目录下所有文件

listAllFiles(ISourceDTO, String, boolean) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

listAllFiles(ISourceDTO, String, boolean) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

获取目录下所有文件的属性集

listConsumerGroup(ISourceDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

获取所有的消费者组

listConsumerGroup(ISourceDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

listConsumerGroupByTopic(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

获取指定topic下的所有的消费者组

listConsumerGroupByTopic(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

listFileNames(ISourceDTO, String, Boolean, Boolean, Integer, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

列出指定路径下的文件

listFileNames(ISourceDTO, String, Boolean, Boolean, Integer, String) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

listStatus(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

listStatus(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

获取目录或者文件的属性

loadClass(String) - 类 中的方法com.dtstack.dtcenter.loader.DtClassLoader

loadClass(String, boolean) - 类 中的方法com.dtstack.dtcenter.loader.DtClassLoader

LongComparator - com.dtstack.dtcenter.loader.dto.comparator中的类

-

LongComparator(long) - 类 的构造器com.dtstack.dtcenter.loader.dto.comparator.LongComparator

longValue() - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.KeyValue

M

main(String[]) - 枚举 中的静态方法com.dtstack.dtcenter.loader.source.DataSourceType

用来计算未使用的最小数据源值

Manager<T> - com.dtstack.dtcenter.loader.cache.pool.manager中的接口

metric - 类 中的变量com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint

指标名称

metric - 类 中的变量com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

MongoSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

MongoSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.MongoSourceDTO

Mysql5SourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

Mysql5SourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.Mysql5SourceDTO

Mysql8SourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

Mysql8SourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.Mysql8SourceDTO

N

newThread(Runnable) - 类 中的方法com.dtstack.dtcenter.loader.factory.DtThreadFactory

已过时。

Node() - 类 的构造器com.dtstack.dtcenter.loader.dto.KafkaPartitionDTO.Node

notBlank(String, String) - 类 中的静态方法com.dtstack.dtcenter.loader.utils.AssertUtils

notNull(Object, String) - 类 中的静态方法com.dtstack.dtcenter.loader.utils.AssertUtils

notNull(Collection, String) - 类 中的静态方法com.dtstack.dtcenter.loader.utils.AssertUtils

NullComparator - com.dtstack.dtcenter.loader.dto.comparator中的类

-

NullComparator() - 类 的构造器com.dtstack.dtcenter.loader.dto.comparator.NullComparator

O

OceanBaseSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

OceanBaseSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.OceanBaseSourceDTO

OdpsSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

OdpsSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.OdpsSourceDTO

OpenTSDBSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

open TSDB 数据源连接信息

OpenTSDBSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.OpenTSDBSourceDTO

OracleSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

OracleSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.OracleSourceDTO

P

PageFilter - com.dtstack.dtcenter.loader.dto.filter中的类

-

PageFilter(long) - 类 的构造器com.dtstack.dtcenter.loader.dto.filter.PageFilter

parent - 类 中的变量com.dtstack.dtcenter.loader.DtClassLoader

The parent class loader.

parseKerberosFromUpload(String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKerberos

从 ZIP 包中解压出 Kerberos 配置信息 其中地址相关信息因为 SFTP 的原因，只存储相对路径，在校验之前再做转化 调用 #IKerberos.prepareKerberosForConnect(java.util.Map<java.lang.String, java.lang.Object>, java.lang.String)

parseKerberosFromUpload(String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.kerberos.KerberosProxy

password - 类 中的变量com.dtstack.dtcenter.loader.dto.source.EMQSourceDTO

密码

password - 类 中的变量com.dtstack.dtcenter.loader.dto.source.RdbmsSourceDTO

密码

password - 类 中的变量com.dtstack.dtcenter.loader.dto.source.S3SourceDTO

密码

password - 类 中的变量com.dtstack.dtcenter.loader.dto.source.WebSocketSourceDTO

密码

Phoenix5SourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

Phoenix5SourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.Phoenix5SourceDTO

PhoenixSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

PhoenixSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.PhoenixSourceDTO

PoolConfig - com.dtstack.dtcenter.loader.cache.pool.config中的类

PoolConfig() - 类 的构造器com.dtstack.dtcenter.loader.cache.pool.config.PoolConfig

post(RestfulSourceDTO, String, Map<String, String>, Map<String, String>) - 接口 中的方法com.dtstack.dtcenter.loader.client.IRestful

post 请求

post(RestfulSourceDTO, String, Map<String, String>, Map<String, String>) - 类 中的方法com.dtstack.dtcenter.loader.client.restful.RestfulClientProxy

PostgresqlSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

PostgresqlSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.PostgresqlSourceDTO

postMultipart(RestfulSourceDTO, Map<String, String>, Map<String, String>, Map<String, String>, Map<String, File>) - 接口 中的方法com.dtstack.dtcenter.loader.client.IRestful

put Multipart

postMultipart(RestfulSourceDTO, Map<String, String>, Map<String, String>, Map<String, String>, Map<String, File>) - 类 中的方法com.dtstack.dtcenter.loader.client.restful.RestfulClientProxy

prepareKerberosForConnect(Map<String, Object>, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKerberos

连接 Kerberos 前的准备工作 1.

prepareKerberosForConnect(Map<String, Object>, String) - 类 中的方法com.dtstack.dtcenter.loader.client.kerberos.KerberosProxy

PrestoSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

presto sourceDTO

PrestoSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.PrestoSourceDTO

preview(ISourceDTO, String, Integer) - 类 中的方法com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

preview(ISourceDTO, String, List<String>, Integer) - 类 中的方法com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

preview(ISourceDTO, String, Map<String, List<String>>, Integer) - 类 中的方法com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

preview(ISourceDTO, String, Integer) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHbase

hbase 数据预览，如果有数据则第一行为字段信息，如果没有数据返回空 list

preview(ISourceDTO, String, List<String>, Integer) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHbase

hbase 数据预览，如果有数据则第一行为字段信息，如果没有数据返回空 list

preview(ISourceDTO, String, Map<String, List<String>>, Integer) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHbase

hbase 数据预览，如果有数据则第一行为字段信息，如果没有数据返回空 list

PRINCIPAL - 类 中的静态变量com.dtstack.dtcenter.loader.kerberos.HadoopConfTool

已过时。

principal 键

PRINCIPAL_FILE - 类 中的静态变量com.dtstack.dtcenter.loader.kerberos.HadoopConfTool

已过时。

principal 文件 键

put(RestfulSourceDTO, String, Map<String, String>, Map<String, String>) - 接口 中的方法com.dtstack.dtcenter.loader.client.IRestful

put 请求

put(RestfulSourceDTO, String, Map<String, String>, Map<String, String>) - 类 中的方法com.dtstack.dtcenter.loader.client.restful.RestfulClientProxy

putRow(ISourceDTO, String, String, String, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

putRow(ISourceDTO, String, String, String, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHbase

hbase向指定的rowKey插入数据

putSync(ISourceDTO, Collection<TsdbPoint>) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITsdb

同步插入多个点位

putSync(ISourceDTO, Collection<TsdbPoint>) - 类 中的方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

Q

Q - 接口 中的静态变量com.dtstack.dtcenter.loader.dto.contant.SolrCommonParams

query string

QT - 接口 中的静态变量com.dtstack.dtcenter.loader.dto.contant.SolrCommonParams

the Request Handler (formerly known as the Query Type) - which Request Handler should handle the request

query(ISourceDTO, TsdbQuery) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITsdb

查询

query(ISourceDTO, TsdbQuery) - 类 中的方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

QueryResult - com.dtstack.dtcenter.loader.dto.tsdb中的类

QueryResult() - 类 的构造器com.dtstack.dtcenter.loader.dto.tsdb.QueryResult

R

RateOptions - com.dtstack.dtcenter.loader.dto.tsdb中的类

RateOptions() - 类 的构造器com.dtstack.dtcenter.loader.dto.tsdb.RateOptions

RdbmsSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

RdbmsSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.RdbmsSourceDTO

reachedEnd() - 类 中的方法com.dtstack.dtcenter.loader.downloader.DownloaderProxy

reachedEnd() - 接口 中的方法com.dtstack.dtcenter.loader.IDownloader

是否末行

readNext() - 类 中的方法com.dtstack.dtcenter.loader.downloader.DownloaderProxy

readNext() - 接口 中的方法com.dtstack.dtcenter.loader.IDownloader

读取下一行

RedisMode - com.dtstack.dtcenter.loader.enums中的枚举

RedisSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

RedisSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.RedisSourceDTO

RegexStringComparator - com.dtstack.dtcenter.loader.dto.comparator中的类

-

RegexStringComparator(String) - 类 的构造器com.dtstack.dtcenter.loader.dto.comparator.RegexStringComparator

Constructor Adds Pattern.DOTALL to the underlying Pattern

RegexStringComparator(String, RegexStringComparator.EngineType) - 类 的构造器com.dtstack.dtcenter.loader.dto.comparator.RegexStringComparator

Constructor Adds Pattern.DOTALL to the underlying Pattern

RegexStringComparator(String, int) - 类 的构造器com.dtstack.dtcenter.loader.dto.comparator.RegexStringComparator

Constructor

RegexStringComparator(String, int, RegexStringComparator.EngineType) - 类 的构造器com.dtstack.dtcenter.loader.dto.comparator.RegexStringComparator

Constructor

RegexStringComparator.EngineType - com.dtstack.dtcenter.loader.dto.comparator中的枚举

removeCacheConnection() - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.CacheConnectionHelper

已过时。

去除缓存配置

rename(ISourceDTO, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

rename(ISourceDTO, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

重命名

renameTable(ISourceDTO, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITable

重命名表，成功返回true，失败返回false

renameTable(ISourceDTO, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.table.TableClientProxy

Response - com.dtstack.dtcenter.loader.dto.restful中的类

http response

Response() - 类 的构造器com.dtstack.dtcenter.loader.dto.restful.Response

RestfulClientFactory - com.dtstack.dtcenter.loader.client.restful中的类

restful 客户端工厂

RestfulClientFactory() - 类 的构造器com.dtstack.dtcenter.loader.client.restful.RestfulClientFactory

RestfulClientProxy - com.dtstack.dtcenter.loader.client.restful中的类

restful 代理类

RestfulClientProxy(IRestful) - 类 的构造器com.dtstack.dtcenter.loader.client.restful.RestfulClientProxy

RestfulSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

restful 数据源信息

RestfulSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.RestfulSourceDTO

REVERSE_ORDER_CMP - 类 中的静态变量com.dtstack.dtcenter.loader.dto.tsdb.QueryResult

RM_PREFIX - 类 中的静态变量com.dtstack.dtcenter.loader.kerberos.HadoopConfTool

已过时。

Resource Manager Configs

RM_PRINCIPAL - 类 中的静态变量com.dtstack.dtcenter.loader.kerberos.HadoopConfTool

已过时。

MR 任务的 Principal 信息，也可以认为是 Yarn 的 Principal

RowFilter - com.dtstack.dtcenter.loader.dto.filter中的类

RowFilter(CompareOp, ByteArrayComparable) - 类 的构造器com.dtstack.dtcenter.loader.dto.filter.RowFilter

ROWS - 接口 中的静态变量com.dtstack.dtcenter.loader.dto.contant.SolrCommonParams

number of documents to return starting at "start"

S

S3SourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

S3SourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.S3SourceDTO

scanByRegex(ISourceDTO, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

scanByRegex(ISourceDTO, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHbase

hbase 根据正则查询匹配的数据，返回rowkey集合

setAlias(String) - 类 中的方法com.dtstack.dtcenter.loader.dto.Column

setComment(String) - 类 中的方法com.dtstack.dtcenter.loader.dto.Column

setConnection(Connection) - 类 中的方法com.dtstack.dtcenter.loader.dto.source.AwsS3SourceDTO

setConnection(Connection) - 类 中的方法com.dtstack.dtcenter.loader.dto.source.EMQSourceDTO

setConnection(Connection) - 类 中的方法com.dtstack.dtcenter.loader.dto.source.FtpSourceDTO

setConnection(Connection) - 类 中的方法com.dtstack.dtcenter.loader.dto.source.HdfsSourceDTO

setConnection(Connection) - 类 中的方法com.dtstack.dtcenter.loader.dto.source.InfluxDBSourceDTO

setConnection(Connection) - 接口 中的方法com.dtstack.dtcenter.loader.dto.source.ISourceDTO

设置 Connection 信息

setConnection(Connection) - 类 中的方法com.dtstack.dtcenter.loader.dto.source.KafkaSourceDTO

setConnection(Connection) - 类 中的方法com.dtstack.dtcenter.loader.dto.source.KylinRestfulSourceDTO

setConnection(Connection) - 类 中的方法com.dtstack.dtcenter.loader.dto.source.MongoSourceDTO

setConnection(Connection) - 类 中的方法com.dtstack.dtcenter.loader.dto.source.OpenTSDBSourceDTO

setConnection(Connection) - 类 中的方法com.dtstack.dtcenter.loader.dto.source.RedisSourceDTO

setConnection(Connection) - 类 中的方法com.dtstack.dtcenter.loader.dto.source.RestfulSourceDTO

setConnection(Connection) - 类 中的方法com.dtstack.dtcenter.loader.dto.source.S3SourceDTO

setConnection(Connection) - 类 中的方法com.dtstack.dtcenter.loader.dto.source.SocketSourceDTO

setConnection(Connection) - 类 中的方法com.dtstack.dtcenter.loader.dto.source.WebSocketSourceDTO

setDefaultFiled(String) - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

默认搜索域

setFields(String...) - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

设置 指定返回结果字段，以空格“ ”或逗号“,”分隔

setFilterIfMissing(boolean) - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.SingleColumnValueFilter

setFilterQueries(String...) - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

设置过滤条件

setIndex(Integer) - 类 中的方法com.dtstack.dtcenter.loader.dto.Column

setLatestVersionOnly(boolean) - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.SingleColumnValueFilter

setName(String) - 类 中的方法com.dtstack.dtcenter.loader.dto.Column

setParam(String, String...) - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

自定义参数

setParam(String, boolean) - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

setPermission(ISourceDTO, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

setPermission(ISourceDTO, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

设置路径权限

setQuery(String) - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

设置查询条件

setRequestHandler(String) - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

setReversed(boolean) - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.RowFilter

setReversed(boolean) - 类 中的方法com.dtstack.dtcenter.loader.dto.filter.SingleColumnValueFilter

setRows(Integer) - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

用于分页定义结果每页返回记录数，默认为10

setShowDebugInfo(boolean) - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

设置返回结果是否显示Debug信息。

setSort(String, SolrQueryDTO.ORDER) - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

排序

setSort(SolrQueryDTO.SortClause) - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

排序

setSorts(List<SolrQueryDTO.SortClause>) - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

排序条件

setStart(Integer) - 类 中的方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO

用于分页定义结果起始记录数，默认为0

setTable(String) - 类 中的方法com.dtstack.dtcenter.loader.dto.Column

setType(String) - 类 中的方法com.dtstack.dtcenter.loader.dto.Column

setUserDir(String) - 类 中的静态方法com.dtstack.dtcenter.loader.client.ClientCache

修改插件包文件夹路径

shortValue() - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.KeyValue

showPartitions(ISourceDTO, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITable

获取所有分区，格式同sql返回值，不错额外处理，如：pt1=name1/pt2=name2/pt3=name3 非分区表返回null

showPartitions(ISourceDTO, String) - 类 中的方法com.dtstack.dtcenter.loader.client.table.TableClientProxy

SingleColumnValueFilter - com.dtstack.dtcenter.loader.dto.filter中的类

用于hbase自定义查询

SingleColumnValueFilter(byte[], byte[], CompareOp, byte[]) - 类 的构造器com.dtstack.dtcenter.loader.dto.filter.SingleColumnValueFilter

SingleColumnValueFilter(byte[], byte[], CompareOp, ByteArrayComparable) - 类 的构造器com.dtstack.dtcenter.loader.dto.filter.SingleColumnValueFilter

SocketSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

socket数据源连接信息

SocketSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.SocketSourceDTO

SolrCommonParams - com.dtstack.dtcenter.loader.dto.contant中的接口

Parameters used across many handlers

SolrQueryDTO - com.dtstack.dtcenter.loader.dto中的类

This is an augmented SolrParams with set fields for common fields used

SolrQueryDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.SolrQueryDTO

SolrQueryDTO(String) - 类 的构造器com.dtstack.dtcenter.loader.dto.SolrQueryDTO

SolrQueryDTO(String, String, String...) - 类 的构造器com.dtstack.dtcenter.loader.dto.SolrQueryDTO

SolrQueryDTO.ORDER - com.dtstack.dtcenter.loader.dto中的枚举

SolrQueryDTO.SortClause - com.dtstack.dtcenter.loader.dto中的类

A single sort clause, encapsulating what to sort and the sort order.

SolrSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

SolrSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.SolrSourceDTO

SORT - 接口 中的静态变量com.dtstack.dtcenter.loader.dto.contant.SolrCommonParams

sort order

SortClause(String, SolrQueryDTO.ORDER) - 类 的构造器com.dtstack.dtcenter.loader.dto.SolrQueryDTO.SortClause

SortClause(String, String) - 类 的构造器com.dtstack.dtcenter.loader.dto.SolrQueryDTO.SortClause

sourceType - 类 中的变量com.dtstack.dtcenter.loader.dto.source.EMQSourceDTO

数据源类型

sourceType - 类 中的变量com.dtstack.dtcenter.loader.dto.source.FtpSourceDTO

数据源类型

sourceType - 类 中的变量com.dtstack.dtcenter.loader.dto.source.KafkaSourceDTO

数据源类型

sourceType - 类 中的变量com.dtstack.dtcenter.loader.dto.source.MongoSourceDTO

数据源类型

sourceType - 类 中的变量com.dtstack.dtcenter.loader.dto.source.RdbmsSourceDTO

数据源类型

sourceType - 类 中的变量com.dtstack.dtcenter.loader.dto.source.RedisSourceDTO

数据源类型

sourceType - 类 中的变量com.dtstack.dtcenter.loader.dto.source.S3SourceDTO

数据源类型

sourceType - 类 中的变量com.dtstack.dtcenter.loader.dto.source.SocketSourceDTO

数据源类型

sourceType - 类 中的变量com.dtstack.dtcenter.loader.dto.source.WebSocketSourceDTO

数据源类型

SparkSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

SparkSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.SparkSourceDTO

SqlQueryDTO - com.dtstack.dtcenter.loader.dto中的类

SqlQueryDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.SqlQueryDTO

Sqlserver2017SourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

Sqlserver2017SourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.Sqlserver2017SourceDTO

SqlserverSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

SqlserverSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.SqlserverSourceDTO

START - 接口 中的静态变量com.dtstack.dtcenter.loader.dto.contant.SolrCommonParams

zero based offset of matching documents to retrieve

startCacheConnection() - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.CacheConnectionHelper

已过时。

startCacheConnection(String) - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.CacheConnectionHelper

已过时。

开启缓存连接池 1.

stopSimilarCacheConnection(String) - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.CacheConnectionHelper

已过时。

根据 sessionKey 查找到类似的 KEY 关闭

stringValue() - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.KeyValue

submit(E) - 接口 中的方法com.dtstack.dtcenter.loader.functions.Callback

执行

SubQuery - com.dtstack.dtcenter.loader.dto.tsdb中的类

SubQuery() - 类 的构造器com.dtstack.dtcenter.loader.dto.tsdb.SubQuery

SubstringComparator - com.dtstack.dtcenter.loader.dto.comparator中的类

-

SubstringComparator(String) - 类 的构造器com.dtstack.dtcenter.loader.dto.comparator.SubstringComparator

Constructor

suggest(ISourceDTO, Suggest, String, int) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITsdb

suggest method

suggest(ISourceDTO, Suggest, String, String, int) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITsdb

suggest method

suggest(ISourceDTO, Suggest, String, int) - 类 中的方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

suggest(ISourceDTO, Suggest, String, String, int) - 类 中的方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

Suggest - com.dtstack.dtcenter.loader.dto.tsdb中的枚举

suggest 类型

T

Table - com.dtstack.dtcenter.loader.dto中的类

Table() - 类 的构造器com.dtstack.dtcenter.loader.dto.Table

TableClientFactory - com.dtstack.dtcenter.loader.client.table中的类

表相关操作客户端工厂

TableClientFactory() - 类 的构造器com.dtstack.dtcenter.loader.client.table.TableClientFactory

TableClientProxy - com.dtstack.dtcenter.loader.client.table中的类

表相关操作客户端代理类

TableClientProxy(ITable) - 类 的构造器com.dtstack.dtcenter.loader.client.table.TableClientProxy

tag(String, String) - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

tag(Map<String, String>) - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

tags - 类 中的变量com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint

tag集合

tags - 类 中的变量com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

tagsToString() - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.QueryResult

tags 转 string

testCon(ISourceDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IClient

校验 连接

testCon(ISourceDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IKafka

校验 连接

testCon(ISourceDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.mq.KafkaClientProxy

testCon(ISourceDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.sql.DataSourceClientProxy

timestamp - 类 中的变量com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint

时间戳

timestamp - 类 中的变量com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

timestamp(long) - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

timestamp(Date) - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

TimestampFilter - com.dtstack.dtcenter.loader.dto.filter中的类

时间戳过滤器

TimestampFilter(CompareOp, Long) - 类 的构造器com.dtstack.dtcenter.loader.dto.filter.TimestampFilter

toString() - 类 中的方法com.dtstack.dtcenter.loader.dto.Column

toString() - 枚举 中的方法com.dtstack.dtcenter.loader.dto.tsdb.Aggregator

toString() - 枚举 中的方法com.dtstack.dtcenter.loader.dto.tsdb.FilterType

toString() - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.KeyValue

toString() - 枚举 中的方法com.dtstack.dtcenter.loader.enums.Granularity

TsdbClientFactory - com.dtstack.dtcenter.loader.client.tsdb中的类

OpenTSDB 客户端工厂

TsdbClientFactory() - 类 的构造器com.dtstack.dtcenter.loader.client.tsdb.TsdbClientFactory

TsdbClientProxy - com.dtstack.dtcenter.loader.client.tsdb中的类

OpenTSDB 代理类

TsdbClientProxy(ITsdb) - 类 的构造器com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

TsdbPoint - com.dtstack.dtcenter.loader.dto.tsdb中的类

TSDB 插入 point

TsdbPoint() - 类 的构造器com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint

TsdbPoint.TsdbPointBuilder - com.dtstack.dtcenter.loader.dto.tsdb中的类

TsdbPointBuilder(String) - 类 的构造器com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

TsdbQuery - com.dtstack.dtcenter.loader.dto.tsdb中的类

OpenTSDB 查询条件

TsdbQuery() - 类 的构造器com.dtstack.dtcenter.loader.dto.tsdb.TsdbQuery

U

updateSessionKey(String) - 类 中的静态方法com.dtstack.dtcenter.loader.cache.connection.CacheConnectionHelper

已过时。

更新缓存唯一键，之前的连接如果存在，直接关闭

updateSessionKey(String) - 类 中的方法com.dtstack.dtcenter.loader.cache.connection.DataSourceConnection

更新 连接主键

uploadInputStreamToHdfs(ISourceDTO, byte[], String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

uploadInputStreamToHdfs(ISourceDTO, byte[], String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

上传字节流到 HDFS

uploadLocalFileToHdfs(ISourceDTO, String, String) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

uploadLocalFileToHdfs(ISourceDTO, String, String) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

上传文件到 HDFS

UpsertColumnMetaDTO - com.dtstack.dtcenter.loader.dto中的类

UpsertColumnMetaDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.UpsertColumnMetaDTO

upsertTableColumn(ISourceDTO, UpsertColumnMetaDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITable

新增或者修改表的列

upsertTableColumn(ISourceDTO, UpsertColumnMetaDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.table.TableClientProxy

url - 类 中的变量com.dtstack.dtcenter.loader.dto.source.EMQSourceDTO

地址

url - 类 中的变量com.dtstack.dtcenter.loader.dto.source.RdbmsSourceDTO

地址

url - 类 中的变量com.dtstack.dtcenter.loader.dto.source.WebSocketSourceDTO

地址

userDir - 类 中的静态变量com.dtstack.dtcenter.loader.client.ClientCache

username - 类 中的变量com.dtstack.dtcenter.loader.dto.source.EMQSourceDTO

用户名

username - 类 中的变量com.dtstack.dtcenter.loader.dto.source.RdbmsSourceDTO

用户名

username - 类 中的变量com.dtstack.dtcenter.loader.dto.source.S3SourceDTO

用户名

username - 类 中的变量com.dtstack.dtcenter.loader.dto.source.WebSocketSourceDTO

用户名

V

value(Object) - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

value(long, Object) - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

value(Date, Object) - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.comparator.BitComparator.BitwiseOp

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.comparator.RegexStringComparator.EngineType

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.filter.FilterList.Operator

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.HbaseQueryDTO.ColumnType

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO.ORDER

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.tsdb.Aggregator

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.tsdb.FilterType

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.tsdb.Suggest

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.CommandType

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.Comparator

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.CompareOp

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.ConnectionClearStatus

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.EsCommandType

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.FileFormat

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.Granularity

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.HbaseFilterType

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.RedisMode

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.source.DataBaseType

已过时。

返回带有指定名称的该类型的枚举常量。

valueOf(String) - 枚举 中的静态方法com.dtstack.dtcenter.loader.source.DataSourceType

返回带有指定名称的该类型的枚举常量。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.comparator.BitComparator.BitwiseOp

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.comparator.RegexStringComparator.EngineType

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.filter.FilterList.Operator

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.HbaseQueryDTO.ColumnType

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.SolrQueryDTO.ORDER

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.tsdb.Aggregator

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.tsdb.FilterType

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.dto.tsdb.Suggest

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.CommandType

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.Comparator

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.CompareOp

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.ConnectionClearStatus

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.EsCommandType

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.FileFormat

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.Granularity

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.HbaseFilterType

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.enums.RedisMode

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.source.DataBaseType

已过时。

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

values() - 枚举 中的静态方法com.dtstack.dtcenter.loader.source.DataSourceType

按照声明该枚举类型的常量的顺序, 返回 包含这些常量的数组。

version(ISourceDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.ITsdb

获取版本号

version(ISourceDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.tsdb.TsdbClientProxy

version(Long) - 类 中的方法com.dtstack.dtcenter.loader.dto.tsdb.TsdbPoint.TsdbPointBuilder

VerticaSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

VerticaSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.VerticaSourceDTO

W

WebSocketSourceDTO - com.dtstack.dtcenter.loader.dto.source中的类

WebSocketSourceDTO() - 类 的构造器com.dtstack.dtcenter.loader.dto.source.WebSocketSourceDTO

writeByName(ISourceDTO, HdfsWriterDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

writeByName(ISourceDTO, HdfsWriterDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

从文件中读取行,根据提供的分隔符号分割,再根据提供的hdfs分隔符合并,写入hdfs ---需要根据column信息判断导入的数据是否符合要求

writeByPos(ISourceDTO, HdfsWriterDTO) - 类 中的方法com.dtstack.dtcenter.loader.client.hdfs.HdfsFileProxy

writeByPos(ISourceDTO, HdfsWriterDTO) - 接口 中的方法com.dtstack.dtcenter.loader.client.IHdfsFile

按位置写入

A B C D E F G H I K L M N O P Q R S T U V W