博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
HBase的JavaAPI使用
阅读量:6590 次
发布时间:2019-06-24

本文共 1566 字,大约阅读时间需要 5 分钟。

Java Client API Overview

HBase是用Java写的,支持用编程语言来动态操作管理数据库,能用命令行做的都能够用API来做。

主要的使用步骤例如以下:

1.创建一个 Configuration 对象

–从 HDFS 对象中调用 Configuration 
–加入 HBase 属性

Configuration conf = HbaseConfiguration.create();

2.创建 HTable
–提供 Configuration 对象
–提供 表名

HTable hTable = new HTable(conf, tableName);

3.运行操作
–如 put, get, scan, delete, etc...

hTable.getTableName();

4.关闭 HTable 实例
–清空缓存
–释放资源

hTable.close();

以下是一个建表的样例:

import java.io.IOException;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.client.HTable;import org.apache.hadoop.hbase.util.Bytes;public class  ConstructHTable{	public static void main(String[] args) throws IOException	{		Configuration conf = HBaseConfiguration.create();		HTable htable = new HTable(conf,"table-created_from_api");		System.out.println("Table :"+Bytes.toString(htable.getTableName()));		htable.close();	}}
以下是插入数据的样例:

import java.io.IOException;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.client.HTable;import org.apache.hadoop.hbase.client.Put;import static org.apache.hadoop.hbase.util.Bytes.*;public class PutExample {	public static void main(String[] args) throws IOException {		Configuration conf = HBaseConfiguration.create();		HTable hTable = new HTable(conf, "HBaseSamples");		Put put1 = new Put(toBytes("row1"));		put1.add(toBytes("test"), toBytes("col1"), toBytes("val1"));		put1.add(toBytes("test"), toBytes("col2"), toBytes("val2"));		hTable.put(put1);		hTable.close();	}}

转载地址:http://sqzio.baihongyu.com/

你可能感兴趣的文章
SpringBoot跨域问题解决方案
查看>>
(转载)hibernate3.0配置文件模板
查看>>
46、练习:输出指定目录下的所有文件名称
查看>>
IP地址与数字地址相互转换
查看>>
.net core 允许跨域
查看>>
Knockout.Js官网学习(创建自定义绑定)
查看>>
win10 x64中 windbg x64 安装配置符号库
查看>>
python 抽象类、抽象方法、接口、依赖注入、SOLIP
查看>>
echarts 报错问题 is null 或者未定义等问题
查看>>
笔记1
查看>>
POJ1068 Parencodings 解题报告
查看>>
webService发布和调用--Axis2
查看>>
递归大总结之台阶问题
查看>>
【通信4.0 重新发明通信网】读后感
查看>>
字符串连接[不用库函数]
查看>>
使用Hystrix实现自动降级与依赖隔离-微服务
查看>>
Parcelbale接口
查看>>
新建一个express工程,node app无反应
查看>>
Python去掉字符串中空格的方法
查看>>
Quartz.net任务调度(石英钟定时任务)
查看>>