Package org.apache.hadoop.hbase.regionserver.querymatcher

Class TestUserScanQueryMatcher

java.lang.Object

org.apache.hadoop.hbase.regionserver.querymatcher.AbstractTestScanQueryMatcher

org.apache.hadoop.hbase.regionserver.querymatcher.TestUserScanQueryMatcher

public class TestUserScanQueryMatcher
extends AbstractTestScanQueryMatcher

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
private static class	TestUserScanQueryMatcher.AlwaysIncludeAndSeekNextRowFilter
private static class	TestUserScanQueryMatcher.AlwaysIncludeFilter

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static final org.slf4j.Logger	LOG

Fields inherited from class org.apache.hadoop.hbase.regionserver.querymatcher.AbstractTestScanQueryMatcher

col1, col2, col3, col4, col5, conf, data, fam1, fam2, get, row1, row2, row3, rowComparator, scan, ttl

Constructor Summary

Constructors

Constructor	Description
TestUserScanQueryMatcher()

Method Summary

Modifier and Type	Method	Description
void	testMatch_ExpiredExplicit()	Verify that ScanQueryMatcher only skips expired KeyValue instances and does not exit early from the row (skipping later non-expired KeyValues).
void	testMatch_ExpiredWildcard()	Verify that ScanQueryMatcher only skips expired KeyValue instances and does not exit early from the row (skipping later non-expired KeyValues).
void	testMatch_Wildcard()
void	testMatchExplicitColumns()
void	testMatchWhenFilterReturnsIncludeAndSeekNextRow()
void	testMergeFilterResponseCase1()	Here is the unit test for UserScanQueryMatcher#mergeFilterResponse, when the number of cells exceed the versions requested in scan, we should return SEEK_NEXT_COL, but if current match code is INCLUDE_AND_SEEK_NEXT_ROW, we can optimize to choose the max step between SEEK_NEXT_COL and INCLUDE_AND_SEEK_NEXT_ROW, which is SEEK_NEXT_ROW.
void	testMergeFilterResponseCase2()	Here is the unit test for UserScanQueryMatcher#mergeFilterResponse: the match code may be changed to SEEK_NEXT_COL or INCLUDE_AND_SEEK_NEXT_COL after merging with filterResponse, even if the passed match code is neither SEEK_NEXT_COL nor INCLUDE_AND_SEEK_NEXT_COL.
void	testNeverIncludeFakeCell()	This is a cryptic test.

Methods inherited from class org.apache.hadoop.hbase.regionserver.querymatcher.AbstractTestScanQueryMatcher

setUp

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

Constructor Details

TestUserScanQueryMatcher

public TestUserScanQueryMatcher()

Method Details

testNeverIncludeFakeCell

public void testNeverIncludeFakeCell()
                              throws IOException

This is a cryptic test. It is checking that we don't include a fake cell, one that has a timestamp of HConstants.OLDEST_TIMESTAMP. See HBASE-16074 for background.

Throws:

IOException

testMatchExplicitColumns

public void testMatchExplicitColumns()
                              throws IOException

Throws:

IOException

testMatch_Wildcard

public void testMatch_Wildcard()
                        throws IOException

Throws:

IOException

testMatch_ExpiredExplicit

public void testMatch_ExpiredExplicit()
                               throws IOException

Verify that ScanQueryMatcher only skips expired KeyValue instances and does not exit early from the row (skipping later non-expired KeyValues). This version mimics a Get with explicitly specified column qualifiers.

Throws:

IOException

testMatch_ExpiredWildcard

public void testMatch_ExpiredWildcard()
                               throws IOException

Verify that ScanQueryMatcher only skips expired KeyValue instances and does not exit early from the row (skipping later non-expired KeyValues). This version mimics a Get with wildcard-inferred column qualifiers.

Throws:

IOException

testMatchWhenFilterReturnsIncludeAndSeekNextRow

public void testMatchWhenFilterReturnsIncludeAndSeekNextRow()
                                                     throws IOException

Throws:

IOException

testMergeFilterResponseCase1

public void testMergeFilterResponseCase1()
                                  throws IOException

Here is the unit test for UserScanQueryMatcher#mergeFilterResponse, when the number of cells exceed the versions requested in scan, we should return SEEK_NEXT_COL, but if current match code is INCLUDE_AND_SEEK_NEXT_ROW, we can optimize to choose the max step between SEEK_NEXT_COL and INCLUDE_AND_SEEK_NEXT_ROW, which is SEEK_NEXT_ROW.

Throws:

IOException

testMergeFilterResponseCase2

public void testMergeFilterResponseCase2()
                                  throws Exception

Here is the unit test for UserScanQueryMatcher#mergeFilterResponse: the match code may be changed to SEEK_NEXT_COL or INCLUDE_AND_SEEK_NEXT_COL after merging with filterResponse, even if the passed match code is neither SEEK_NEXT_COL nor INCLUDE_AND_SEEK_NEXT_COL. In that case, we need to make sure that the ColumnTracker has been switched to the next column.
An effective test way is: we only need to check the cell from getKeyForNextColumn(). because that as long as the UserScanQueryMatcher returns SEEK_NEXT_COL or INCLUDE_AND_SEEK_NEXT_COL, UserScanQueryMatcher#getKeyForNextColumn should return an cell whose column is larger than the current cell's.

Throws:

Exception