[hbase] hbase column addFamily, SingleColumnValueFilter 예제

다음 hbase 커맨드는 다음 의사 자바 코드와 같다.

<hbase 커맨드>

scan 'table', { COLUMNS => 'colFam:colQualifier', LIMIT => 3 }

<java psudeo code>

    Scan scan = new Scan();

    scan.addFamily(Bytes.toBytes(familyName));

    filters.addFilter(pageFilter);

    scan.setFilter(filters);

다음 hbase 커맨드는 다음 의사 자바 코드와 같다.

<hbase 커맨드>

scan 'table', { COLUMNS => 'colFam:colQualifier', LIMIT => 3, FILTER => "ValueFilter( =, 'value1' )" }

<java psudeo code>

        Scan scan = new Scan();

        FilterList filters = new FilterList(FilterList.Operator.MUST_PASS_ALL);

        Filter pageFilter = new PageFilter(fetchSize);

        

        SingleColumnValueFilter qualifierFilter = new SingleColumnValueFilter(

                COLUMN_FAMILY,

                COLUMN_QUALIFIER,

                CompareFilter.CompareOp.EQUAL,

                new BinaryComparator(Bytes.toBytes("value1"))

        );

        filters.addFilter(pageFilter);

        filters.addFilter(qualifierFilter);

        scan.setFilter(filters);