Hbase的java

153次閱讀

共計(jì) 2521 個(gè)字符，預(yù)計(jì)需要花費(fèi) 7 分鐘才能閱讀完成。

今天就跟大家聊聊有關(guān) Hbase 的 java_API 操作，可能很多人都不太了解，為了讓大家更加了解，丸趣 TV 小編給大家總結(jié)了以下內(nèi)容，希望大家根據(jù)這篇文章可以有所收獲。

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 {
//  創(chuàng)建表、刪除表使用 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);
//  插入記錄、查詢(xún)一條記錄、查詢(xún)所有記錄 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);
}

看完上述內(nèi)容，你們對(duì) Hbase 的 java_API 操作有進(jìn)一步的了解嗎？如果還想了解更多知識(shí)或者相關(guān)內(nèi)容，請(qǐng)關(guān)注丸趣 TV 行業(yè)資訊頻道，感謝大家的支持。

正文完