使用 Java API 操作 HBase

使用 Java API 操作 HBase 数据库，就类似HBase Shell，本质上一个是Java 代码，一个是Shell 命令。（hadoop 的文件系统莫不如此，可用Java API 的方式操作hdfs，也可用shell 命令）。

在hbase 操作一文我们介绍了使用命令行（HBase shell）的方式操作hbase，如果 Java 也可操作MySQL一样，本文我们着重介绍如何使用 Java API 操作 HBase。

hadoop hbase API 提供了两个核心的 API 用以操作hbase 数据库：

HBaseAdmin：
- 创建表：create
- 删除表：disable、drop
HTable：
- 插入记录：put
- 删除记录：delete、deleteall
- 遍历所有记录：scan

public class Test {private static final String TABLE_NAME = "students";private static final String FAMILY_1 = "stu_id";private static final String FAMILY_2 = "addr";private static final String FAMILY_3 = "info";public static void main(String[] args) throws Exception {Configuration conf = HBaseConfiguration.create();conf.set("hbase.rootdir", "hdfs://hadoop0:hbase/");conf.set("hbase.zookeeper.quorum", "hadoop0");HBaseAdmin admin = new HBaseAdmin(conf);if (!admin.tableExists(TABLE_NAME)){HTableDescriptor desc = new HTableDescriptor(TABLE_NAME);desc.addFamily(new HColumnDescriptor(FAMILY_1));desc.addFamily(new HColumnDescriptor(FAMILY_2));desc.addFamily(new HColumnDescriptor(FAMILY_3));admin.createTable(desc);// 等价于 hbase shell 中的：// create 'students', 'stu_id', 'addr', 'info'}HTable table = new HTable(conf, TABLE_NAME);Put put = new Put("xiaoming".getBytes());put.add(FAMILY_3.getBytes(), "age".getBytes(), "24".getBytes());// 一个 add 表示插入一个记录// put 'students', 'xiaoming', 'info:age', "24"put.add(FAMILY_3.getBytes(), "birthday".getBytes(), "1987-06-17".getBytes());put.add(FAMILY_3.getBytes(), "company".getBytes(), "alibba".getBytes());put.add(FAMILY_2.getBytes(), "contry".getBytes(), "china".getBytes());put.add(FAMILY_2.getBytes(), "province".getBytes(), "zhejiang".getBytes());put.add(FAMILY_2.getBytes(), "city".getBytes(), "hangzhou".getBytes());table.put(put);put = new Put("zhangyifei".getBytes());put.add(FAMILY_3.getBytes(), "birthday".getBytes(), "1987-04-17".getBytes());put.add(FAMILY_2.getBytes(), "city".getBytes(), "jieyang".getBytes());table.put(put);// 查询//  get 'students', 'xiaoming', 'info:company'Get get = new Get("xiaoming".getBytes());Result result = table.get(get);             // 得到的是整条记录System.out.println(new String(result.getValue(FAMILY_3.getBytes(), "company".getBytes())));
//      System.out.println(result);// 查询全部信息，scan 'students'Scan scan = new Scan();ResultScanner scanner = table.getScanner(scan);for (Result res : scanner) {System.out.println(res);}table.close();}
}

使用 Java API 操作 HBase相关推荐

HBase 6、用Phoenix Java api操作HBase
开发环境准备:eclipse3.5.jdk1.7.window8.hadoop2.2.0.hbase0.98.0.2.phoenix4.3.0 1.从集群拷贝以下文件:core-site.xml.hb ...
Java Api 操作 Hbase
文章目录 1.需求 2.思路 2.1 建立远程Hbase集群连接 -- HbaseInit.java 2.2 创建表结构--CreateTable.java 2.3 插入数据 -- PutRow.ja ...
Hbase java API操作(模板代码)
Hbase java API操作 1 创建maven工程导入jar包 <repositories><repository><id>cloudera</id& ...
Hbase 完全分布式模式的搭建、命令行操作、Java API操作
追风赶月莫停留,平芜尽处是春山. 文章目录追风赶月莫停留,平芜尽处是春山. 环境 Hbase 完全分布式模式的搭建一.下载安装包,解压到合适位置: 二.配置相关的文件: 三.将Hbase复制到其他 ...
6 HBase java API访问HBase数据库
HBase java API访问HBase数据库 package com.hunan.hbase_options;import org.apache.hadoop.conf.Configuration ...
2021年大数据ZooKeeper（五）：ZooKeeper Java API操作
目录 ZooKeeper Java API操作引入maven坐标节点的操作 ZooKeeper Java API操作这里操作Zookeeper的JavaAPI使用的是一套zookeeper客户端 ...
Kafka系列三 java API操作
使用java API操作kafka 1.pom.xml <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xs ...
Hadoop详解（四）：HDFS shell操作和Java API操作
1. HDFS环境准备 1.1 HDFS的格式化与启动 HDFS配置完之后就可以对其进行格式化操作.在NameNode所在机器上执行如下命令进行HDFS的格式化操作: hadoop namenode ...
Windows下使用Java API操作HDFS的常用方法
场景 Windows下配置Hadoop的Java开发环境以及用Java API操作HDFS: https://blog.csdn.net/BADAO_LIUMANG_QIZHI/article/det ...

使用 Java API 操作 HBase

使用 Java API 操作 HBase相关推荐

最新文章

热门文章