Shulou(Shulou.com)06/01 Report--

Today, I will talk to you about the java_API operation of Hbase. Many people may not know much about it. In order to let you know more, Xiaobian summarizes the following contents for you. I hope you can gain something according to this article.

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 {//Create table, delete table Use HbaseAdminConfiguration 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);//insert record, query one record, query all records HTableHTable 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 tableDescriptor = new HTableDescriptor(TABLE_NAME);HColumnDescriptor family = new HColumnDescriptor(FAMILY_NAME); tableDescriptor.addFamily(family);hBaseAdmin.createTable(tableDescriptor);}}} After reading the above contents, do you have any further understanding of java_API operation of Hbase? If you still want to know more knowledge or related content, please pay attention to the industry information channel, thank you for your support.

Welcome to subscribe "Shulou Technology Information " to get latest news, interesting things and hot topics in the IT industry, and controls the hottest and latest Internet news, technology news and IT industry trends.