HBase的JAVA API操作详解

Alt+/ 代码助手完成一些代码的插入，自动显示提示信息  

Alt+↓ 当前行和下面一行交互位置(特别实用,可以省去先剪切,再粘贴了)

Alt+↑  当前行和上面一行交互位置(同上)

Alt+← 前一个编辑的页面 

Alt+→ 下一个编辑的页面(当然是针对上面那条来说了)

Alt+Shift+M 抽取方法

Alt+Shift+L 抽取本地变量  

Ctrl+1 快速修复  

package Hbase; import java.io.IOException; import java.io.InterruptedIOException; import java.util.List; 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.Get; import org.apache.hadoop.hbase.client.HBaseAdmin; import org.apache.hadoop.hbase.client.HTable; import org.apache.hadoop.hbase.client.Put; import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.ResultScanner; import org.apache.hadoop.hbase.client.RetriesExhaustedWithDetailsException; import org.apache.hadoop.hbase.client.Scan; public class test { private static final String Table_NAME = "table1"; //表名称 private static final String FAMILY_NAME = "family1"; //列族名称 private static final String ROW_KEY = "rowkey1"; //创建行健 //创建，插入，查询记录，遍历表，删除表 public static void main(String[] args) throws Exception { Configuration conf= HBaseConfiguration.create(); conf.set("hbase.rootdir","hdfs://localhost:9000/hbase"); //设置hbase再hdfs中的目录 conf.set("hbase.zookeeper.quorum", "localhost"); //使用zookeeper来进行定位 //创建删除表使用HBaseAdmin HBaseAdmin hBaseAdmin = new HBaseAdmin(conf); createTable(hBaseAdmin); //创建表 //插入记录，查询一条记录，遍历所有的记录Table final HTable hTable = new HTable(conf, Table_NAME); putRecord(hTable); //插入一条记录 getRecord(hTable); //查询一条记录 scanTable(hTable); //遍历所有的表的记录 hTable.close(); //关闭表 //deleteTable(hBaseAdmin); //删除表 } private static void scanTable(final HTable hTable) throws IOException { Scan scan = new Scan(); final ResultScanner scanner = hTable.getScanner(scan); for (Result result : scanner) { final byte[] value = result.getValue(FAMILY_NAME.getBytes() , "age".getBytes()); System.out.println(result+"\t" + new String(value)); } } private static void getRecord(final HTable hTable) throws IOException { Get get = new Get(ROW_KEY.getBytes()); final Result result = hTable.get(get ); final byte[] value = result.getValue(FAMILY_NAME.getBytes() , "age".getBytes()); System.out.println(result+"\t" + new String(value)); } private static void putRecord(HTable hTable) throws InterruptedIOException, RetriesExhaustedWithDetailsException { Put put = new Put(ROW_KEY.getBytes()); //声明对象 put.add(FAMILY_NAME .getBytes(), "age".getBytes()," 12".getBytes()); //添加记录 hTable.put(put ); //插入 } private static void deleteTable(HBaseAdmin hBaseAdmin) throws IOException { hBaseAdmin.disableTable(Table_NAME); //关闭表 hBaseAdmin.deleteTable(Table_NAME); //删除表 } private static void createTable(HBaseAdmin hBaseAdmin) throws IOException { if (!hBaseAdmin.tableExists(Table_NAME)){ HTableDescriptor tableDescriptor = new HTableDescriptor(Table_NAME); //声明一个表 HColumnDescriptor family = new HColumnDescriptor(FAMILY_NAME); //声明一个列族 tableDescriptor.addFamily(family ); //添加列族 hBaseAdmin.createTable(tableDescriptor ); //创建表 } } }