com.dtstack.dtcenter.loader.client.hbase

类 HbaseProxy

java.lang.Object

com.dtstack.dtcenter.loader.client.hbase.HbaseProxy

所有已实现的接口:

IHbase

public class HbaseProxy
extends Object
implements IHbase

hbase客户端代理

作者:

：wangchuan date：Created in 9:38 上午 2020/12/2 company: www.dtstack.com

构造器概要

构造器

构造器和说明
HbaseProxy(IHbase hbase)

方法概要

限定符和类型	方法和说明
Boolean	createHbaseTable(ISourceDTO source, String tableName, String[] colFamily) hbase创建表
Boolean	createHbaseTable(ISourceDTO source, String namespace, String tableName, String[] colFamily) hbase创建表，指定namespace
Boolean	deleteByRowKey(ISourceDTO source, String tableName, String family, String qualifier, List<String> rowKeys) hbase 根据rowKey删除数据
Boolean	deleteHbaseTable(ISourceDTO source, String tableName) hbase 删除表
Boolean	deleteHbaseTable(ISourceDTO source, String namespace, String tableName) hbase 删除表
List<Map<String,Object>>	executeQuery(ISourceDTO source, HbaseQueryDTO hbaseQueryDTO, TimestampFilter timestampFilter) hbase 自定义查询
String	getRow(ISourceDTO source, String tableName, String rowKey, String family, String qualifier) hbase根据rowKey获取数据
Boolean	isDbExists(ISourceDTO source, String namespace) 判断namespace是否存在
List<List<String>>	preview(ISourceDTO source, String tableName, Integer previewNum) hbase 数据预览，如果有数据则第一行为字段信息，如果没有数据返回空 list
List<List<String>>	preview(ISourceDTO source, String tableName, List<String> familyList, Integer previewNum) hbase 数据预览，如果有数据则第一行为字段信息，如果没有数据返回空 list
List<List<String>>	preview(ISourceDTO source, String tableName, Map<String,List<String>> familyQualifierMap, Integer previewNum) hbase 数据预览，如果有数据则第一行为字段信息，如果没有数据返回空 list
Boolean	putRow(ISourceDTO source, String tableName, String rowKey, String family, String qualifier, String data) hbase向指定的rowKey插入数据
List<String>	scanByRegex(ISourceDTO source, String tableName, String regex) hbase 根据正则查询匹配的数据，返回rowkey集合

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

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

构造器详细资料

HbaseProxy

public HbaseProxy(IHbase hbase)

方法详细资料

isDbExists

public Boolean isDbExists(ISourceDTO source,
                          String namespace)

从接口复制的说明: IHbase

判断namespace是否存在

指定者:

isDbExists 在接口中 IHbase

参数:

source - 数据源信息

namespace - hbase namespace

返回:

是否存在

createHbaseTable

public Boolean createHbaseTable(ISourceDTO source,
                                String tableName,
                                String[] colFamily)

从接口复制的说明: IHbase

hbase创建表

指定者:

createHbaseTable 在接口中 IHbase

参数:

source - 数据源信息

tableName - 表名

colFamily - 列族列表

返回:

创建结果

createHbaseTable

public Boolean createHbaseTable(ISourceDTO source,
                                String namespace,
                                String tableName,
                                String[] colFamily)

从接口复制的说明: IHbase

hbase创建表，指定namespace

指定者:

createHbaseTable 在接口中 IHbase

参数:

source - 数据源信息

namespace - hbase namespace

tableName - 表名

colFamily - 列族列表

返回:

创建结果

deleteHbaseTable

public Boolean deleteHbaseTable(ISourceDTO source,
                                String tableName)

从接口复制的说明: IHbase

hbase 删除表

指定者:

deleteHbaseTable 在接口中 IHbase

参数:

source - 数据源信息

tableName - 表名

deleteHbaseTable

public Boolean deleteHbaseTable(ISourceDTO source,
                                String namespace,
                                String tableName)

从接口复制的说明: IHbase

hbase 删除表

指定者:

deleteHbaseTable 在接口中 IHbase

参数:

source - 数据源信息

tableName - 表名

scanByRegex

public List<String> scanByRegex(ISourceDTO source,
                                String tableName,
                                String regex)

从接口复制的说明: IHbase

hbase 根据正则查询匹配的数据，返回rowkey集合

指定者:

scanByRegex 在接口中 IHbase

参数:

source - 数据源连接信息

tableName - 表名

regex - 匹配正则

返回:

查询结果

deleteByRowKey

public Boolean deleteByRowKey(ISourceDTO source,
                              String tableName,
                              String family,
                              String qualifier,
                              List<String> rowKeys)

从接口复制的说明: IHbase

hbase 根据rowKey删除数据

指定者:

deleteByRowKey 在接口中 IHbase

参数:

source - 数据源信息

tableName - 表名

rowKeys - rowkey列表

返回:

删除状态

putRow

public Boolean putRow(ISourceDTO source,
                      String tableName,
                      String rowKey,
                      String family,
                      String qualifier,
                      String data)

从接口复制的说明: IHbase

hbase向指定的rowKey插入数据

指定者:

putRow 在接口中 IHbase

参数:

source - 数据源信息

tableName - 表名

rowKey - hbase rowkey

family - 列族

qualifier - 列名

data - 数据

返回:

数据插入状态

getRow

public String getRow(ISourceDTO source,
                     String tableName,
                     String rowKey,
                     String family,
                     String qualifier)

从接口复制的说明: IHbase

hbase根据rowKey获取数据

指定者:

getRow 在接口中 IHbase

参数:

source - 数据源信息

tableName - 表名

rowKey - hbase rowkey

返回:

查询结果

preview

public List<List<String>> preview(ISourceDTO source,
                                  String tableName,
                                  Integer previewNum)

从接口复制的说明: IHbase

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

指定者:

preview 在接口中 IHbase

参数:

source - 数据源信息

tableName - 表名

previewNum - 预览条数，最大5000条 默认100条

返回:

预览数据

preview

public List<List<String>> preview(ISourceDTO source,
                                  String tableName,
                                  List<String> familyList,
                                  Integer previewNum)

从接口复制的说明: IHbase

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

指定者:

preview 在接口中 IHbase

参数:

source - 数据源信息

tableName - 表名

familyList - 预览指定列族的数据，即当前行如果有满足该列族的数据就返回

previewNum - 预览条数，最大5000条 默认100条

返回:

预览数据

preview

public List<List<String>> preview(ISourceDTO source,
                                  String tableName,
                                  Map<String,List<String>> familyQualifierMap,
                                  Integer previewNum)

从接口复制的说明: IHbase

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

指定者:

preview 在接口中 IHbase

参数:

source - 数据源信息

tableName - 表名

familyQualifierMap - 预览指定列族、列名下的数据

previewNum - 预览条数，最大5000条 默认100条

返回:

预览数据

executeQuery

public List<Map<String,Object>> executeQuery(ISourceDTO source,
                                             HbaseQueryDTO hbaseQueryDTO,
                                             TimestampFilter timestampFilter)

从接口复制的说明: IHbase

hbase 自定义查询

指定者:

executeQuery 在接口中 IHbase

参数:

source - 数据源信息

hbaseQueryDTO - hbase 查询条件

timestampFilter - 时间戳过滤

返回:

查询结果