import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.HTableDescriptor; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Admin; import org.apache.hadoop.hbase.client.Result; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.data.hadoop.hbase.HbaseTemplate; import java.io.IOException; import java.util.Arrays; import java.util.Objects; /** * hbase工具类 * * @ClassName: HBaseUtils * @author kanpiaoxue * @version 1.0 * @CreateTime: 2020/11/24 16:18:55 * @Description: */ public class HBaseUtils { private static final Logger LOGGER = LoggerFactory.getLogger(HBaseUtils.class); public static byte[] getValue(HbaseTemplate hbaseTemplate, String tableName, byte[] columnFamily, byte[] column, String rowKey) { byte[] rs = hbaseTemplate.get(tableName, rowKey, (Result result, int rowNum) -> { byte[] value = result.getValue(columnFamily, column); if (Objects.isNull(value)) { return null; } return value; }); return rs; } public static boolean isExistColumnFamily(Admin admin, TableName tableName, String cf) throws IOException { HTableDescriptor tableDescriptor = admin.getTableDescriptor(tableName); HColumnDescriptor[] descriptors = tableDescriptor.getColumnFamilies(); return Arrays.stream(descriptors).filter(descriptor -> { String name = descriptor.getNameAsString(); LOGGER.info("tableName:{},columnFamily name:{},cf:{}", tableName, name, cf); return name.equals(cf); }).findFirst().isPresent(); } public static boolean isExistTable(Admin admin, TableName tableName) throws IOException { return admin.tableExists(tableName); } public static void write(HbaseTemplate hbaseTemplate, String tableName, String columnFamily, String column, String rowKey, byte[] value) { hbaseTemplate.put(tableName, rowKey, columnFamily, column, value); } /** * */ private HBaseUtils() { super(); } }
相关推荐
hbase表操作工具类.连接hbase数据库,根据rowkey删除单条记录,批量删除记录。获取某个字段的值,判断记录是否存在,向hbase表中插单条数据,批量插入到hbase表。 查询表,获取某个字段的值列表,hbase工具
java开发连接hbase的jar包,1.2.1版本的hbase-client.jar,还有其他jar包,很全
该资源内容主要包含:两个版本常用mongoTemplate操作数据库集合语句的整理
文章目录HBASE 工具类HBASE 高可用搭建 HBASE 工具类 package com.day_219; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.client.HBaseAdmin; import org.apache.hadoop.hbase....
hbase监控工具hbtop CDH6.3.2版本,用于监控表、namespace的访问情况,可快速定位问题
这个是hbase的压缩文件,用linux或者redhat系统,解压之后修改配置文件就可以使用
nosql-实验三HBase管理工具和客户端
hbase+ycsb工具
1、有多个工具可选择使用
由于网上下的不支持最新的hadoop,hbase 版本自己稍微修改了下,支持最新版本HBase的图形化管理工具,目前修改改为hadoop-2.7.1版本,hbase-1.1.2版本,依赖可以自己切换,源代码已经包括再里边了,如想修改直接修改...
使用java工具类可有效的提高开发效率! 没有CSDN积分的朋友到这里源头下载:http://www.javacs.cn/bbs/thread-382-1-1.html 感谢支持 [工具类] CookieCounter .java.txt [工具类] 验证码img .jsp.txt [工具类] Java中...
[工具类] CookieCounter .java.txt [工具类] 验证码img .jsp.txt [工具类] Java中计算任意两个日期之间的工作天数 .java.txt [工具类] java抓取网页 .java.txt [工具类] MD5 .java.txt [工具类] MD5强化版 .java.txt...
hbase 修复工具,hbck 编译好
该资源为java客户端连接hbase集群,在windows客户端配置hadoop环境所需要用到的工具类,有需自取
Hbase 可视化客户端工具(非phoenix连接),支持Hbase1.x,配置方便,类似PL/SQL,是一个HBase数据库的客户端数据管理软件。
该工具类下载后拷贝到你要用的包,只需该包名即可
hbase 安装包 。。
SpringJdbcTemplate封装工具包,包括规范model格式接口,封装SpringJdbcTemplate,实现分页,自适应多种数据库
J2EE常用工具类汇总 J2EE常用工具类—Value Object工具类 J2EE常用工具类—Json工具 J2EE常用工具类—Jdbc操作 J2EE常用工具类—Hibernate操作 J2EE常用工具类—Cookie操作 J2EE常用工具类—数组操作 J2EE...