HBase的javaApi一個應用（建立刪除表等）
阿新 • • 發佈：2019-02-18
本文為傳智播客hadoop八天——第六天學習筆記
目的：使用HBase提供的api在eclipse中建立表，刪除表，查詢資料，使用過濾器有選擇的查詢資料
在啟動HBase之前一定要啟動Hadoop和Zookeeper！！今天調了一上午的錯，竟然是因為沒啟動Zookeeper。o（╥﹏╥）o
以下為java程式碼。
package cn.bigdata;
import java.util.ArrayList;
import java.util.List;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import HBase提供了很多篩選的過濾器，用於scan方法
/**
* 多種過濾條件的使用方法
* @throws Exception
*/
@Test
public void testScan() throws Exception{
HTable table = new HTable(conf, "person_info".getBytes());
Scan scan = new Scan(Bytes.toBytes("person_rk_bj_zhang_000001"), Bytes.toBytes("person_rk_bj_zhang_000002"));
// 字首過濾器----針對行鍵
Filter filter = new PrefixFilter(Bytes.toBytes("rk"));
// 行過濾器
ByteArrayComparable rowComparator = new BinaryComparator(
Bytes.toBytes("person_rk_bj_zhang_000001"));
RowFilter rf = new RowFilter(CompareOp.LESS_OR_EQUAL, rowComparator);
/**
* 假設rowkey格式為：建立日期_釋出日期_ID_TITLE 目標：查詢 釋出日期 為 2014-12-21 的資料
*/
rf = new RowFilter(CompareOp.EQUAL, new SubstringComparator(
"_2014-12-21_"));
// 單值過濾器 1 完整匹配位元組陣列
new SingleColumnValueFilter("base_info".getBytes(), "name".getBytes(),
CompareOp.EQUAL, "zhangsan".getBytes());
// 單值過濾器2 匹配正則表示式
ByteArrayComparable comparator = new RegexStringComparator("zhang.");
new SingleColumnValueFilter("info".getBytes(), "NAME".getBytes(),
CompareOp.EQUAL, comparator);
// 單值過濾器2 匹配是否包含子串,大小寫不敏感
comparator = new SubstringComparator("wu");
new SingleColumnValueFilter("info".getBytes(), "NAME".getBytes(),
CompareOp.EQUAL, comparator);
// 鍵值對元資料過濾-----family過濾----位元組陣列完整匹配
FamilyFilter ff = new FamilyFilter(CompareOp.EQUAL,
new BinaryComparator(Bytes.toBytes("base_info")) // 表中不存在inf列族，過濾結果為空
);
// 鍵值對元資料過濾-----family過濾----位元組陣列字首匹配
ff = new FamilyFilter(CompareOp.EQUAL, new BinaryPrefixComparator(
Bytes.toBytes("inf")) // 表中存在以inf打頭的列族info，過濾結果為該列族所有行
);
// 鍵值對元資料過濾-----qualifier過濾----位元組陣列完整匹配
filter = new QualifierFilter(CompareOp.EQUAL, new BinaryComparator(
Bytes.toBytes("na")) // 表中不存在na列，過濾結果為空
);
filter = new QualifierFilter(CompareOp.EQUAL,
new BinaryPrefixComparator(Bytes.toBytes("na")) // 表中存在以na打頭的列name，過濾結果為所有行的該列資料
);
// 基於列名(即Qualifier)字首過濾資料的ColumnPrefixFilter
filter = new ColumnPrefixFilter("na".getBytes());
// 基於列名(即Qualifier)多個字首過濾資料的MultipleColumnPrefixFilter
byte[][] prefixes = new byte[][] { Bytes.toBytes("na"),
Bytes.toBytes("me") };
filter = new MultipleColumnPrefixFilter(prefixes);
// 為查詢設定過濾條件
scan.setFilter(filter);
scan.addFamily(Bytes.toBytes("base_info"));
ResultScanner scanner = testDemo.getScanner(scan);
for (Result r : scanner) {
// 直接從result中取到某個特定的value
byte[] value = r.getValue(Bytes.toBytes("base_info"),
Bytes.toBytes("name"));
System.out.println(new String(value));
}
testDemo.close();
}