使用Java API对HBase进行操作
2013-08-20 11:07
549 查看
import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.HTableDescriptor; import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.client.HBaseAdmin; import org.apache.hadoop.hbase.client.HTable; import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.ResultScanner; import org.apache.hadoop.hbase.client.Scan; import org.apache.hadoop.hbase.io.BatchUpdate; @SuppressWarnings("deprecation") public class HBaseTestCase { static HBaseConfiguration cfg = null; static { Configuration HBASE_CONFIG = new Configuration(); HBASE_CONFIG.set("hbase.zookeeper.quorum", "192.168.50.216"); HBASE_CONFIG.set("hbase.zookeeper.property.clientPort", "2181"); cfg = new HBaseConfiguration(HBASE_CONFIG); } /** * 创建一张表 */ public static void creatTable(String tablename) throws Exception { HBaseAdmin admin = new HBaseAdmin(cfg); if (admin.tableExists(tablename)) { System.out.println("table Exists!!!"); } else{ HTableDescriptor tableDesc = new HTableDescriptor(tablename); tableDesc.addFamily(new HColumnDescriptor("name:")); admin.createTable(tableDesc); System.out.println("create table ok ."); } } /** * 添加一条数据 */ public static void addData (String tablename) throws Exception{ HTable table = new HTable(cfg, tablename); BatchUpdate update = new BatchUpdate("Huangyi"); update.put("name:java", "http://www.javabloger.com".getBytes()); table.commit(update); System.out.println("add data ok ."); } /** * 显示所有数据 */ public static void getAllData (String tablename) throws Exception{ HTable table = new HTable(cfg, tablename); Scan s = new Scan(); ResultScanner ss = table.getScanner(s); for(Result r:ss){ for(KeyValue kv:r.raw()){ System.out.print(new String(kv.getColumn())); System.out.println(new String(kv.getValue() )); } } } public static void main (String [] agrs) { try { String tablename="tablename"; HBaseTestCase.creatTable(tablename); HBaseTestCase.addData(tablename); HBaseTestCase.getAllData(tablename); } catch (Exception e) { e.printStackTrace(); } } }
相关文章推荐
- 使用Java Api 对HBase进行简单操作
- eclipse下使用java api 进行hbase的常用的操作所需的jar包,以及如何查看java build path下的jar是否使用
- 使用Java Api 对HBase进行简单操作
- 使用Java API对HBase进行CRUD操作
- Hbase单机安装及使用hbase shell进行简单操作
- 使用java api操作hbase数据库
- Python 使用 Thrift 连接 HBASE 进行操作
- Hbase单机安装及使用hbase shell进行简单操作
- [置顶] Java API连接HBase 进行增删查改操作
- 使用 FileSystem JAVA API 对 HDFS 进行读、写、删除等操作
- HBase Java API使用操作例子
- Hbase总结(三)--使用spring-data-hadoop进行hbase的读写操作
- 通过Java Api对Hbase进行操作
- Elasticsearch简单使用系列--使用Java API进行CRUD操作
- HBase.使用shell脚本进行HBase操作
- Elasticsearch简单使用系列--使用Java API进行CRUD操作
- Hbase之使用回调函数进行批处理操作
- hadoop(02)、使用JAVA API对HDFS进行基本操作
- 使用mybatis进行批量插入操作带序列
- 使用JavaScript下进行iframe的DOM操作(考虑浏览器兼容性)