com.dtstack.dtcenter.loader.client

接口 IHbase

所有已知实现类:

HbaseProxy

public interface IHbase

hbase客户端接口

作者:

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

方法概要

限定符和类型	方法和说明
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集合

方法详细资料

isDbExists

Boolean isDbExists(ISourceDTO source,
                   String namespace)

判断namespace是否存在

参数:

source - 数据源信息

namespace - hbase namespace

返回:

是否存在

createHbaseTable

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

hbase创建表

参数:

source - 数据源信息

tableName - 表名

colFamily - 列族列表

返回:

创建结果

createHbaseTable

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

hbase创建表，指定namespace

参数:

source - 数据源信息

namespace - hbase namespace

tableName - 表名

colFamily - 列族列表

返回:

创建结果

deleteHbaseTable

Boolean deleteHbaseTable(ISourceDTO source,
                         String tableName)

hbase 删除表

参数:

source - 数据源信息

tableName - 表名

deleteHbaseTable

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

hbase 删除表

参数:

source - 数据源信息

tableName - 表名

scanByRegex

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

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

参数:

source - 数据源连接信息

tableName - 表名

regex - 匹配正则

返回:

查询结果

deleteByRowKey

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

hbase 根据rowKey删除数据

参数:

source - 数据源信息

tableName - 表名

rowKeys - rowkey列表

返回:

删除状态

putRow

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

hbase向指定的rowKey插入数据

参数:

source - 数据源信息

tableName - 表名

rowKey - hbase rowkey

family - 列族

qualifier - 列名

data - 数据

返回:

数据插入状态

getRow

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

hbase根据rowKey获取数据

参数:

source - 数据源信息

tableName - 表名

rowKey - hbase rowkey

返回:

查询结果

preview

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

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

参数:

source - 数据源信息

tableName - 表名

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

返回:

预览数据

preview

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

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

参数:

source - 数据源信息

tableName - 表名

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

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

返回:

预览数据

preview

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

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

参数:

source - 数据源信息

tableName - 表名

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

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

返回:

预览数据

executeQuery

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

hbase 自定义查询

参数:

source - 数据源信息

hbaseQueryDTO - hbase 查询条件

timestampFilter - 时间戳过滤

返回:

查询结果