Java应用程序put操作.docxVIP

Java应用程序put操作　　1,创建表　　2,put操作　　public class myHbase {　　private static Configuration conf= null;　　static {　　conf=HBaseConfiguration.create（）；　　}　　/**　　* column familys add column ---hbase columnName　　* @param tableName　　* @param familys　　* @throws Exception　　*/　　public void createTable（String tableName,String[] familys） throws Exception{　　HBaseAdmin admin = new HBaseAdmin（conf）；　　if（！admin.tableExists（tableName））{　　HTableDescriptor desc = new HTableDescriptor（tableName）；　　for （int i = 0; i familys.length; i++） {　　desc.addFamily（new HColumnDescriptor（familys[i]））；　　}　　admin.createTable（desc）；　　}else{　　System.out.println（the table:+ tableName + exsists）；　　};　　}　　/**　　* @param tableName　　* @param rowKey　　* @param family　　* @param qualifier　　* @param value　　* @throws Exception　　*/　　public void putData（String tableName,String rowKey, String family,　　String qualifier, String value） throws Exception {　　HTable ht = new HTable（conf, tableName）；　　Put put = new Put（Bytes.toBytes（rowKey））；　　put.add（Bytes.toBytes（family）， Bytes.toBytes（qualifier）， Bytes.toBytes（value））；　　ht.put（put）；　　}　　public static void main（String [] agrs） throws Exception{　　myHbase h= new myHbase（）；　　String [] familys = {family1,family2};　　h.createTable（mytable, familys）；　　h.putData（mytable, row, family1, qualifier:name1, value1）；　　}　　}　　运行java应用程序：登录hbase shell 发现可以get和scan到数据了：　　hbase（main）：016:0 scan mytable　　ROW COLUMN+CELL　　row column=family1:qualifier:name1, timestamp=1354559928275, v　　alue=value1　　1 row（s） in 0.0410 seconds　　hbase（main）：017:0 get mytable,row,family1:qualifier:name1　　COLUMN CELL　　family1:qualifier:na timestamp=1354559928275, value=value1　　me1　　1 row（s） in 0.0120 seconds（ps：本文章由北大青鸟广安门校区搜集自互联网）