SpringBoot-HBase

演示的是阿里云的HBase

一.POM<dependency><groupId>com.aliyun.hbase</groupId><artifactId>alihbase-client</artifactId><version>1.1.1</version></dependency>
二.
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HConstants;
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.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
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.Table;public class HandlerHBase {private static final String TABLE_NAME = "表名随便写";private static final String ZK_ADDRESS = "地址1,地址2";public static void main(String[] args) throws IOException {createData("userId-1".getBytes(), "routeId-1".getBytes(), "drivingSpeed".getBytes(), "500km/h".getBytes());System.out.println("=====================插入完毕==============");System.out.println(getData("userId-1".getBytes(), "routeId-1".getBytes(), "drivingSpeed".getBytes()));}public static void createData(byte[] rowKey, byte[] family, byte[] colum, byte[] value) throws IOException {Configuration config = HBaseConfiguration.create();config.set(HConstants.ZOOKEEPER_QUORUM, ZK_ADDRESS);TableName tn = TableName.valueOf(TABLE_NAME);try (Connection connection = ConnectionFactory.createConnection(config);Table table = connection.getTable(tn);) {HTableDescriptor tableDescriptor = new HTableDescriptor(tn);tableDescriptor.addFamily(new HColumnDescriptor(family));Admin admin = connection.getAdmin();if (!admin.tableExists(tn)) {admin.createTable(tableDescriptor);}Put put = new Put(rowKey);put.addColumn(family, colum, value);table.put(put);}}public static String getData(byte[] rowKey, byte[] family, byte[] colum) throws IOException {Configuration config = HBaseConfiguration.create();config.set(HConstants.ZOOKEEPER_QUORUM, ZK_ADDRESS);TableName tn = TableName.valueOf(TABLE_NAME);try (Connection connection = ConnectionFactory.createConnection(config);Table table = connection.getTable(tn);) {HTableDescriptor tableDescriptor = new HTableDescriptor(tn);tableDescriptor.addFamily(new HColumnDescriptor(family));Admin admin = connection.getAdmin();if (!admin.tableExists(tn)) {admin.createTable(tableDescriptor);}Get get = new Get(rowKey);Result r = table.get(get);byte[] value = r.getValue(family, colum);return new String(value);}}
}

SpringBoot-HBase相关推荐

springboot+hbase 集成
项目中使用 phoenix 使用SQL 方式来操作Hbase 数据库,但是遇到一个是,SQL在Dbeaver 中查询速度还可以,但是使用phoenix+ibatis 后返回结果集数据量20w ,速度特 ...
springboot hbase
1.添加依赖 <hbase.version>2.2.4</hbase.version> <dependency><groupId>org.apache. ...
springboot HBase操作工具类
JAVA_基础部分_综合篇
JVM (1) 基本概念: JVM是可运行Java代码的假想计算机 ,包括一套字节码指令集.一组寄存器.一个栈.一个垃圾回收,堆和一个存储方法域.JVM 是运行在操作系统之上的,它与硬件没有直接的 ...
springboot整合postgre和hbase实现互相交互功能
此项目是一个小测试,将postgre中的某些字段读取到hbase中变成某个表的列族,其中postgre和hbase已经在云服务器上建立好,用的docker技术,开放相应端口,并且win上用管道安全连接 ...
SpringBoot整合HBase将数据写入Docker中的HBase
在之前的项目里,docker容器中已经运行了HBase,现将API操作HBase实现数据的增删改查通过SpringBoot整合Hbase是一个很好的选择首先打开IDEA,创建项目(project) ...
springboot 整合hbase
前言作为大数据家族中的重要一员,在大数据以及海量数据存储方面,hbase具有重要的地方,本篇将从java对hbase的操作上,进行详细的说明: HBase 定义 HBase 是一种分布式.可扩展.支 ...
Hbase+Phoenix+Mybatis+Springboot整合查询数据
Phoenix Query Server提供了一种与Phoenix和HBase交互的替代方法.很快,这将允许从JVM以外的环境进行访问. 在4.x和5.0版本中,查询服务器及其JDBC客户端是标准Ph ...
Springboot集成Hadoop+Hbase实现企业能源消耗监测大数据分析系统
企业硬件设备较多,不利于快速发现设备故障及能源消耗异常.依托于hadoop.hbase搭建大数据分析平台,采用Springboot开发框架搭建一套完善的企业能源监控检测数据分析可视化平台.本次毕设程序 ...
SpringBoot 使用Phoenix操作HBase数据库教程
SpringBoot 使用Phoenix操作HBase数据库教程文章目录添加 Phoenix 相关依赖控制器实现Hbase数据库操作好的html源码下载文章目录借助 Apache Phoe ...

SpringBoot-HBase

SpringBoot-HBase相关推荐

最新文章

热门文章