.../hadoop/hbase/client/TestFromClientSide.java | 24 ++++++++++++++++++++++ 1 file changed, 24 insertions(+) diff --git a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide.java b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide.java index ca4b609..d558ae2 100644 --- a/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide.java +++ b/hbase-server/src/test/java/org/apache/hadoop/hbase/client/TestFromClientSide.java @@ -73,6 +73,7 @@ import org.apache.hadoop.hbase.filter.FirstKeyOnlyFilter; import org.apache.hadoop.hbase.filter.InclusiveStopFilter; import org.apache.hadoop.hbase.filter.KeyOnlyFilter; import org.apache.hadoop.hbase.filter.LongComparator; +import org.apache.hadoop.hbase.filter.PageFilter; import org.apache.hadoop.hbase.filter.PrefixFilter; import org.apache.hadoop.hbase.filter.QualifierFilter; import org.apache.hadoop.hbase.filter.RegexStringComparator; @@ -6074,6 +6075,29 @@ public class TestFromClientSide { } } } + + @Test + public void testPgFilter() throws IOException { + TableName TABLE = TableName.valueOf("testPgFilter"); + Table table = TEST_UTIL.createTable(TABLE, FAMILY); + List putList = new ArrayList(); + for (int i = 0; i < 10; i++) { + Put p = new Put(Bytes.toBytes("row" + i)); + p.addColumn(FAMILY, QUALIFIER, VALUE); + putList.add(p); + } + table.put(putList); + Scan scan = new Scan(); + scan.setCaching(5); + scan.setReversed(true); + //FilterList list = new FilterList(new PageFilter(5)); + scan.setFilter(new PageFilter(5)); + ResultScanner scanner = table.getScanner(scan); + Iterator iterator = scanner.iterator(); + while(iterator.hasNext()) { + System.out.println(iterator.next()); + } + } @Test public void testFilterAllRecords() throws IOException {