com.dtstack.dtcenter.loader.client

类 ClientCache

java.lang.Object

com.dtstack.dtcenter.loader.client.ClientCache

直接已知子类:

DataSourceClientCache, HdfsFileClientCache, KafkaClientCache

public class ClientCache
extends Object

字段概要

字段

限定符和类型	字段和说明
protected static String	userDir

构造器概要

构造器

构造器和说明
ClientCache()

方法概要

限定符和类型	方法和说明
static IClient	getClient(Integer sourceType) 获取 Sql Client 客户端
static IClient	getClient(String pluginName) 已过时。
static IHbase	getHbase(Integer sourceType) 获取 hbase 服务客户端
static IHdfsFile	getHdfs(Integer sourceType) 获取 HDFS 文件客户端
static IHdfsFile	getHdfs(String pluginName) 已过时。
static IKafka	getKafka(Integer sourceType) 获取 KAFKA 客户端
static IKafka	getKafka(String pluginName) 已过时。
static IKerberos	getKerberos(Integer sourceType) 获取 Kerberos 服务客户端
static IRestful	getRestful(Integer sourceType) 获取 restful Client 客户端
static ITable	getTable(Integer sourceType) 获取 table Client 客户端
static ITsdb	getTsdb(Integer sourceType) 获取 tsdb Client 客户端
static String	getUserDir() 获取插件包文件夹路径
static void	setUserDir(String dir) 修改插件包文件夹路径

从类继承的方法 java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

字段详细资料

userDir

protected static String userDir

构造器详细资料

ClientCache

public ClientCache()

方法详细资料

setUserDir

public static void setUserDir(String dir)

修改插件包文件夹路径

参数:

dir -

getUserDir

public static String getUserDir()

获取插件包文件夹路径

返回:

getClient

public static IClient getClient(Integer sourceType)
                         throws ClientAccessException

获取 Sql Client 客户端

参数:

sourceType -

返回:

抛出:

ClientAccessException

getClient

@Deprecated
public static IClient getClient(String pluginName)
                                     throws ClientAccessException

已过时。

获取 Sql Client 客户端

参数:

pluginName -

返回:

抛出:

ClientAccessException

getHdfs

public static IHdfsFile getHdfs(Integer sourceType)
                         throws ClientAccessException

获取 HDFS 文件客户端

参数:

sourceType -

返回:

抛出:

ClientAccessException

getHdfs

@Deprecated
public static IHdfsFile getHdfs(String pluginName)
                                     throws ClientAccessException

已过时。

获取 HDFS 文件客户端

参数:

pluginName -

返回:

抛出:

ClientAccessException

getKafka

public static IKafka getKafka(Integer sourceType)
                       throws ClientAccessException

获取 KAFKA 客户端

参数:

sourceType -

返回:

抛出:

ClientAccessException

getKafka

@Deprecated
public static IKafka getKafka(String pluginName)
                                   throws ClientAccessException

已过时。

获取 KAFKA 客户端

参数:

pluginName -

返回:

抛出:

ClientAccessException

getKerberos

public static IKerberos getKerberos(Integer sourceType)
                             throws ClientAccessException

获取 Kerberos 服务客户端

参数:

sourceType -

返回:

抛出:

ClientAccessException

getHbase

public static IHbase getHbase(Integer sourceType)
                       throws ClientAccessException

获取 hbase 服务客户端

参数:

sourceType - 数据源类型

返回:

hbase新客户端

抛出:

ClientAccessException - 插件化加载异常

getTable

public static ITable getTable(Integer sourceType)
                       throws ClientAccessException

获取 table Client 客户端

参数:

sourceType -

返回:

抛出:

ClientAccessException

getTsdb

public static ITsdb getTsdb(Integer sourceType)

获取 tsdb Client 客户端

参数:

sourceType - 数据源类型

返回:

tsdb Client 客户端

getRestful

public static IRestful getRestful(Integer sourceType)

获取 restful Client 客户端

参数:

sourceType - 数据源类型

返回:

restful Client 客户端