다음 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);


Posted by '김용환'
,