标签：String family tableName param public IOException 操作 Hbase 工具
- hbase 依赖jar包
<dependency>
<groupId>org.apache.hbase</groupId>
<artifactId>hbase-client</artifactId>
<version>2.0.5</version>
</dependency>
- 工具类
package javax.utils;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Get;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;
/**
* Hbase 操作工具类
*
* @author Logan
* @version 1.0.0
* @createDate 2019-05-03
*
*/
public class HbaseUtils {
// ===============Common=====================================
/**
* 根据表名获取Table对象
*
* @param name 表名，必要时可指定命名空间，比如：“default:user”
* @return Hbase Table 对象
* @throws IOException 有异常抛出，由调用者捕获处理
*/
public static Table getTable(String name) throws IOException {
TableName tableName = TableName.valueOf(name);
Connection connection = ConnectionFactory.createConnection();
return connection.getTable(tableName);
}
// =============== Put =====================================
/**
* 根据rowKey生成一个Put对象
*
* @param rowKey rowKey
* @return Put对象
*/
public static Put createPut(String rowKey) {
return new Put(Bytes.toBytes(rowKey));
}
/**
* 在Put对象上增加Cell
*
* @param put Put对象
* @param cell cell对象
* @throws IOException 有异常抛出，由调用者捕获处理
*/
public static void addCellOnPut(Put put, Cell cell) throws IOException {
put.add(cell);
}
/**
* 在Put对象上增加值
*
* @param put Put对象
* @param family 列簇
* @param qualifier 列
* @param value 字符串类型的值
*/
public static void addValueOnPut(Put put, String family, String qualifier, String value) {
addValueOnPut(put, family, qualifier, Bytes.toBytes(value));
}
/**
* 在Put对象上增加值
*
* @param put Put对象
* @param family 列簇
* @param qualifier 列
* @param value 字节数组类型的值，可以是任意对象序列化而成
*/
public static void addValueOnPut(Put put, String family, String qualifier, byte[] value) {
put.addColumn(Bytes.toBytes(family), Bytes.toBytes(qualifier), value);
}
/**
* 在Put对象上增加值
*
* @param put Put对象
* @param family 列簇
* @param qualifier 列
* @param ts Timestamp时间戳
* @param value 字符串类型的值
*/
public static void addValueOnPut(Put put, String family, String qualifier, long ts, String value) {
addValueOnPut(put, family, qualifier, ts, Bytes.toBytes(value));
}
/**
* 在Put对象上增加值
*
* @param put Put对象
* @param family 列簇
* @param qualifier 列
* @param ts Timestamp时间戳
* @param value 字节数组类型的值，可以是任意对象序列化而成
*/
public static void addValueOnPut(Put put, String family, String qualifier, long ts, byte[] value) {
put.addColumn(Bytes.toBytes(family), Bytes.toBytes(qualifier), ts, value);
}
/**
* 按表名插入一个Put对象包含的数据
*
* @param tableName 表名，必要时可指定命名空间，比如：“default:user”
* @param put 要插入的数据对象
* @throws IOException 有异常抛出，由调用者捕获处理
*/
public static void put(String tableName, Put put) throws IOException {
try (
Table table = getTable(tableName);
) {
table.put(put);
}
}
/**
* 按表名批量插入Put对象包含的数据
*
* @param tableName 表名，必要时可指定命名空间，比如：“default:user”
* @param puts 要插入的数据对象集合
* @throws IOException 有异常抛出，由调用者捕获处理
*/
public static void put(String tableName, List<Put> puts) throws IOException {
try (
Table table = getTable(tableName);
) {
table.put(puts);
}
}
// =============== Get =====================================
/**
* 根据rowKey生成一个查询的Get对象
*
* @param rowKey rowKey
* @return Get 对象
*/
public static Get createGet(String rowKey) {
return new Get(Bytes.toBytes(rowKey));
}
/**
* 对查询的Get对象增加指定列簇
*
* @param get
* @param family
*/
public static void addFamilyOnGet(Get get, String family) {
get.addFamily(Bytes.toBytes(family));
}
/**
* 对查询的Get对象增加指定列簇和列
*
* @param get
* @param family
* @param qualifier
*/
public static void addColumnOnGet(Get get, String family, String qualifier) {
get.addColumn(Bytes.toBytes(family), Bytes.toBytes(qualifier));
}
/**
* 根据表名和rowKey查询结果（包含全部列簇和列）
*
* @param tableName 表名，必要时可指定命名空间，比如：“default:user”
* @param rowKey 查询rowKey
* @return 查询结果Result
* @throws IOException 有异常抛出，由调用者捕获处理
*/
public static Result get(String tableName, String rowKey) throws IOException {
Get get = createGet(rowKey);
return get(tableName, get);
}
/**
* 根据表名和rowKey数组批量查询结果（包含全部列簇和列）
*
* @param tableName 表名，必要时可指定命名空间，比如：“default:user”
* @param rowKeys 查询rowKey数组
* @return 查询结果Result数组
* @throws IOException 有异常抛出，由调用者捕获处理
*/
public static Result[] get(String tableName, String[] rowKeys) throws IOException {
List<Get> gets = new ArrayList<Get>();
for (String rowKey : rowKeys) {
gets.add(createGet(rowKey));
}
return get(tableName, gets);
}
/**
* 根据表名和Get对象查询结果
*
* @param tableName 表名，必要时可指定命名空间，比如：“default:user”
* @param get Hbase查询对象
* @return 查询结果Result
* @throws IOException 有异常抛出，由调用者捕获处理
*/
public static Result get(String tableName, Get get) throws IOException {
try (
Table table = getTable(tableName);
) {
return table.get(get);
}
}
/**
* 根据表名和Get对象数组查询结果
*
* @param tableName 表名，必要时可指定命名空间，比如：“default:user”
* @param gets 多个Hbase查询对象组成的数组
* @return 查询结果Result数组
* @throws IOException 有异常抛出，由调用者捕获处理
*/
public static Result[] get(String tableName, List<Get> gets) throws IOException {
try (
Table table = getTable(tableName);
) {
return table.get(gets);
}
}
// =============== Scan =====================================
/**
* 根据startRow和stopRow创建扫描对象
*
* @param startRow 扫描开始行，结果包含该行
* @param stopRow 扫描结束行，结果不包含该行
* @return Scan对象
*/
public static Scan createScan(String startRow, String stopRow) {
Scan scan = new Scan();
scan.withStartRow(Bytes.toBytes(startRow));
scan.withStopRow(Bytes.toBytes(stopRow));
return scan;
}
/**
* 对扫描对象设置列簇
*
* @param scan 扫描对象
* @param family 列簇
*/
public static void addFamilyOnScan(Scan scan, String family) {
scan.addFamily(Bytes.toBytes(family));
}
/**
* 对扫描对象设置列
*
* @param scan 扫描对象
* @param family 列簇
* @param qualifier 列簇下对应的列
*/
public static void addColumnOnScan(Scan scan, String family, String qualifier) {
scan.addColumn(Bytes.toBytes(family), Bytes.toBytes(qualifier));
}
/**
* 根据表名和扫描对象扫描数据
*
* @param tableName 表名，必要时可指定命名空间，比如：“default:user”
* @param scan 扫描对象
* @return 扫描结果集对象ResultScanner
* @throws IOException 有异常抛出，由调用者捕获处理
*/
public static ResultScanner scan(String tableName, Scan scan) throws IOException {
try (
Table table = getTable(tableName);
) {
return table.getScanner(scan);
}
}
/**
* 根据表名、开始行和结束行扫描数据（结果包含开始行，不包含结束行，半开半闭区间[startRow, stopRow)）
*
* @param tableName 表名，必要时可指定命名空间，比如：“default:user”
* @param startRow 扫描开始行
* @param stopRow 扫描结束行
* @return 扫描结果集对象ResultScanner
* @throws IOException 有异常抛出，由调用者捕获处理
*/
public static ResultScanner scan(String tableName, String startRow, String stopRow) throws IOException {
return scan(tableName, createScan(startRow, stopRow));
}
// =============== Delete =====================================
/**
* 根据rowKey生成一个查询的Delete对象
*
* @param rowKey rowKey
* @return Delete对象
*/
public static Delete createDelete(String rowKey) {
return new Delete(Bytes.toBytes(rowKey));
}
/**
* 在Delete对象上增加Cell
*
* @param delete Delete对象
* @param cell cell对象
* @throws IOException 有异常抛出，由调用者捕获处理
*/
public static void addCellOnDelete(Delete delete, Cell cell) throws IOException {
delete.add(cell);
}
/**
* 对删除对象增加指定列簇
*
* @param delete Delete对象
* @param family 列簇
*/
public static void addFamilyOnDelete(Delete delete, String family) {
delete.addFamily(Bytes.toBytes(family));
}
/**
* 对删除对象增加指定列簇和列
*
* @param delete Delete对象
* @param family 列簇
* @param qualifier 列
*/
public static void addColumnOnDelete(Delete delete, String family, String qualifier) {
delete.addColumn(Bytes.toBytes(family), Bytes.toBytes(qualifier));
}
/**
* 按表名删除一个Delete对象指定的数据
*
* @param tableName 表名，必要时可指定命名空间，比如：“default:user”
* @param delete Delete对象
* @throws IOException 有异常抛出，由调用者捕获处理
*/
public static void delete(String tableName, Delete delete) throws IOException {
try (
Table table = getTable(tableName);
) {
table.delete(delete);
}
}
/**
* 按表名批量删除Delete对象集合包含的指定数据
*
* @param tableName 表名，必要时可指定命名空间，比如：“default:user”
* @param deletes Delete对象集合
* @throws IOException 有异常抛出，由调用者捕获处理
*/
public static void delete(String tableName, List<Delete> deletes) throws IOException {
try (
Table table = getTable(tableName);
) {
table.delete(deletes);
}
}
}
标签：String,family,tableName,param,public,IOException,操作,Hbase,工具 来源： https://www.cnblogs.com/luweiweicode/p/14072713.html
本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享； 2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关； 3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关； 4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除； 5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。