What is the java_API operation of Hbase?
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.
