Apache
/
hbase
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

HBASE-16303 FilterList with MUST_PASS_ONE optimization (Ram)

This commit is contained in:
Ramkrishna 2016-08-05 10:58:02 +05:30
parent 5e23b3aad5
commit 19c609fa5e
2 changed files with 8 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestFilter.java
View File

@ -315,6 +315,7 @@ public class TestFilter {
verifyScan(s, expectedRows, expectedKeys); verifyScan(s, expectedRows, expectedKeys);
} }
@Test
public void testPrefixFilterWithReverseScan() throws Exception { public void testPrefixFilterWithReverseScan() throws Exception {
// Grab rows from group one (half of total) // Grab rows from group one (half of total)
long expectedRows = this.numRows / 2; long expectedRows = this.numRows / 2;
@ -412,6 +413,7 @@ public class TestFilter {
} }
@Test
public void testPageFilterWithReverseScan() throws Exception { public void testPageFilterWithReverseScan() throws Exception {
// KVs in first 6 rows // KVs in first 6 rows
KeyValue[] expectedKVs = { KeyValue[] expectedKVs = {
@ -491,6 +493,7 @@ public class TestFilter {
verifyScan(s, expectedRows, expectedKeys); verifyScan(s, expectedRows, expectedKeys);
} }
@Test
public void testWhileMatchFilterWithFilterRowWithReverseScan() public void testWhileMatchFilterWithFilterRowWithReverseScan()
throws Exception { throws Exception {
final int pageSize = 4; final int pageSize = 4;
@ -520,6 +523,7 @@ public class TestFilter {
pageSize, scannerCounter); pageSize, scannerCounter);
} }
@Test
public void testWhileMatchFilterWithFilterRowKeyWithReverseScan() public void testWhileMatchFilterWithFilterRowKeyWithReverseScan()
throws Exception { throws Exception {
Scan s = new Scan(); Scan s = new Scan();
@ -1766,6 +1770,7 @@ public class TestFilter {
kvs.length, idx); kvs.length, idx);
} }
@Test
public void testColumnPaginationFilterColumnOffset() throws Exception { public void testColumnPaginationFilterColumnOffset() throws Exception {
KeyValue [] expectedKVs = { KeyValue [] expectedKVs = {
// testRowOne-0 // testRowOne-0

3
hbase-server/src/test/java/org/apache/hadoop/hbase/filter/TestFilterList.java
View File

@ -262,6 +262,7 @@ public class TestFilterList {
* we expect to get the same result as the 'prefix' only result. * we expect to get the same result as the 'prefix' only result.
* @throws Exception * @throws Exception
*/ */
@Test
public void testFilterListTwoFiltersMustPassOne() throws Exception { public void testFilterListTwoFiltersMustPassOne() throws Exception {
byte[] r1 = Bytes.toBytes("Row1"); byte[] r1 = Bytes.toBytes("Row1");
byte[] r11 = Bytes.toBytes("Row11"); byte[] r11 = Bytes.toBytes("Row11");
@ -294,6 +295,7 @@ public class TestFilterList {
* we expect to get the same result as the inclusive stop result. * we expect to get the same result as the inclusive stop result.
* @throws Exception * @throws Exception
*/ */
@Test
public void testFilterListWithInclusiveStopFilteMustPassOne() throws Exception { public void testFilterListWithInclusiveStopFilteMustPassOne() throws Exception {
byte[] r1 = Bytes.toBytes("Row1"); byte[] r1 = Bytes.toBytes("Row1");
byte[] r11 = Bytes.toBytes("Row11"); byte[] r11 = Bytes.toBytes("Row11");
@ -353,6 +355,7 @@ public class TestFilterList {
* Test filterKeyValue logic. * Test filterKeyValue logic.
* @throws Exception * @throws Exception
*/ */
@Test
public void testFilterKeyValue() throws Exception { public void testFilterKeyValue() throws Exception {
Filter includeFilter = new FilterBase() { Filter includeFilter = new FilterBase() {
@Override @Override