码迷,mamicode.com
首页 > 编程语言 > 详细

HBase的JavaAPI使用

时间:2014-05-31 20:13:17      阅读:370      评论:0      收藏:0      [点我收藏+]

标签:c   style   class   code   java   a   

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();
	}
}


HBase的JavaAPI使用,布布扣,bubuko.com

HBase的JavaAPI使用

标签:c   style   class   code   java   a   

原文地址:http://www.cnblogs.com/lcchuguo/p/3762288.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!