Hbase的java_API操作是怎样的
今天就跟大家聊聊有关Hbase的java_API操作,可能很多人都不太了解,为了让大家更加了解,小编给大家总结了以下内容,希望大家根据这篇文章可以有所收获。
创新互联专业为企业提供仁和网站建设、仁和做网站、仁和网站设计、仁和网站制作等企业网站建设、网页设计与制作、仁和企业网站模板建站服务,10年仁和做网站经验,不只是建网站,更提供有价值的思路和整体网络服务。
package Hbase; import java.io.IOException; 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.MasterNotRunningException; import org.apache.hadoop.hbase.ZooKeeperConnectionException; 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.Scan; public class HbaseApp { public static final String TABLE_NAME = "table1"; public static final String FAMILY_NAME = "family1"; public static final String ROW_KEY = "rowkey1"; public static void main(String[] args) throws Exception { // 创建表、删除表使用HbaseAdmin Configuration conf = HBaseConfiguration.create(); conf.set("hbase.rootdir", "hdfs://hadoop:9000/hbase"); conf.set("hbase.zookeeper.quorum", "hadoop"); HBaseAdmin hBaseAdmin = new HBaseAdmin(conf); //createTable(hBaseAdmin); //deleteTabele(hBaseAdmin); // 插入记录、查询一条记录、查询所有记录HTable HTable hTable = new HTable(conf, TABLE_NAME); //putRecord(hTable); //getRecord(hTable); Scan scan = new Scan(); ResultScanner scanner = hTable.getScanner(scan); for (Result result : scanner) { byte[] value = result.getValue(FAMILY_NAME.getBytes(), "age".getBytes()); System.out.println(result+"\t"+ new String(value)); } hTable.close(); } private static void getRecord(HTable hTable) throws IOException { Get get = new Get(ROW_KEY.getBytes()); Result result = hTable.get(get); System.out.println(new String(result.getValue(FAMILY_NAME.getBytes(), "age".getBytes()))); } private static void putRecord(HTable hTable) throws IOException { Put put = new Put(ROW_KEY.getBytes()); put.add(FAMILY_NAME.getBytes(),"age".getBytes(),"25".getBytes()); hTable.put(put); } private static void deleteTabele(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 tableDescripetor = new HTableDescriptor(TABLE_NAME); HColumnDescriptor family = new HColumnDescriptor(FAMILY_NAME); tableDescripetor.addFamily(family); hBaseAdmin.createTable(tableDescripetor); } } }
看完上述内容,你们对Hbase的java_API操作有进一步的了解吗?如果还想了解更多知识或者相关内容,请关注创新互联行业资讯频道,感谢大家的支持。
分享题目:Hbase的java_API操作是怎样的
网站网址:http://ybzwz.com/article/pojdoh.html