scan的操作: hbase(main):002:0> scan 'scores'
public static void scanBySingleColumnValueFilter(String tableName, String family, String qual, String value) throws IOException {//这个地方需要注意value的数据类型,否则及其容易出错 HTable table = new HTable(conf, tableName); byte[] b_family = Bytes.toBytes(family); byte[] b_qual = Bytes.toBytes(qual); byte[] b_value = Bytes.toBytes(value); FilterList filterList = new FilterList(); SingleColumnValueFilter singleColumnValueFilter = new SingleColumnValueFilter( b_family, b_qual, CompareOp.EQUAL, b_value); // singleColumnValueFilter.setFilterIfMissing(true); filterList.addFilter(singleColumnValueFilter); Scan scan = new Scan(); scan.setFilter(filterList); scan.addColumn(b_family, b_qual); ResultScanner rs = table.getScanner(scan); showResultScanner(rs); }
show结果 public static void showResultScanner(ResultScanner rs){ 在主函数里调用的时候 System.out.println("=========== scanBySingleColumnValueFilter =======");
HBaseClient.scanBySingleColumnValueFilter(tablename, "course", "art", "87"); 结果: =========== scanBySingleColumnValueFilter =======
|
|
来自: IT技术武馆 > 《Hadoop及生态圈相关》