标签:
用过以后,总得写个总结,不然,就忘喽。
一、寻找操作的jar包。
java操作hbase,首先要考虑到使用hbase的jar包。
因为咱装的是CDH5,比较方便,使用SecureCRT工具,远程连接到你安装的那台服务器上。
jar包的存放位置在/opt/cloudera/parcels/CDH/lib/hbase,找到,下载下来。
在当前路径下,有一个lib包,里面是支持hbase的hadoop的jar包,根据需求,可以下载下来。
二、找一个API文档当成手册,哪里不会查哪里
百度分享,http://pan.baidu.com/s/1jICqdgy,可以下载。
三、java操作Hbase。
构造函数:
public static Configuration configuration; static{ configuration = HBaseConfiguration.create(); configuration.set("hbase.master","ip1:60000"); configuration.set("hbase.zookeeper.quorum", "ip1:2181,ip2:2181") ; }
1、如何创建一个hbase表并put数据。
public static void creaTable(String tablename) throws Exception{ HBaseAdmin admin = new HBaseAdmin(configuration); if(admin.tableExists(tablename)){ admin.disableTable(tablename); admin.deleteTable(tablename); System.out.println("开始创建表!"); } System.out.println("新的表正在创建中!!!"); HTableDescriptor tableDescriptor = new HTableDescriptor(tablename); tableDescriptor.addFamily(new HColumnDescriptor("cf1")); admin.createTable(tableDescriptor); Put put = new Put("123".getBytes()); put.add("cf1".getBytes(), "colum1".getBytes(), "value1".getBytes()) ; put.add("cf1".getBytes(), "colum2".getBytes(), "value2".getBytes()) ; put.add("cf1".getBytes(), "colum3".getBytes(), "value3".getBytes()) ; Put put2 = new Put("234".getBytes()) ; put2.add("cf1".getBytes(), "colum1".getBytes(), "value1".getBytes()) ; put2.add("cf1".getBytes(), "colum2".getBytes(), "value2".getBytes()) ; put2.add("cf1".getBytes(), "colum3".getBytes(), "value3".getBytes()) ; HTable table = new HTable(configuration, tablename); table.put(put); table.put(put2); }
2、删除hbase中的table里面的rowkey
标签:
原文地址:http://www.cnblogs.com/invban/p/5667701.html