public class TestScannerBlockSizeLimits extends Object
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static byte[] |
COLUMN1 |
private static byte[] |
COLUMN2 |
private static byte[] |
COLUMN3 |
private static byte[] |
COLUMN5 |
private static byte[] |
DATA |
private static byte[][] |
FAMILIES |
private static byte[] |
FAMILY1 |
private static byte[] |
FAMILY2 |
private static org.apache.hadoop.hbase.TableName |
TABLE |
private static HBaseTestingUtil |
TEST_UTIL |
Constructor and Description |
---|
TestScannerBlockSizeLimits() |
Modifier and Type | Method and Description |
---|---|
private static void |
createTestData() |
private org.apache.hadoop.hbase.client.Scan |
getBaseScan()
We enable cursors and partial results to give us more granularity over counting of results, and
we enable STREAM so that no auto switching from pread to stream occurs -- this throws off the
rpc counts.
|
static void |
setUp() |
void |
setupEach() |
void |
testCheckLimitAfterFilteringCell()
At the end of the loop in StoreScanner, we do one more check of size limits.
|
void |
testCheckLimitAfterFilteringRowCells()
After RegionScannerImpl.populateResults, row filters are run.
|
void |
testCheckLimitAfterFilteringRowCellsDueToFilterRow()
After RegionScannerImpl.populateResults, row filters are run.
|
void |
testCheckLimitAfterFilterRowKey()
Tests that we check size limit after filterRowKey.
|
void |
testSeekNextUsingHint()
Tests that when we seek over blocks we dont include them in the block size of the request
|
void |
testSingleBlock()
Simplest test that ensures we don't count block sizes too much.
|
public static final HBaseClassTestRule CLASS_RULE
private static final HBaseTestingUtil TEST_UTIL
private static final org.apache.hadoop.hbase.TableName TABLE
private static final byte[] FAMILY1
private static final byte[] FAMILY2
private static final byte[] DATA
private static final byte[][] FAMILIES
private static final byte[] COLUMN1
private static final byte[] COLUMN2
private static final byte[] COLUMN3
private static final byte[] COLUMN5
public TestScannerBlockSizeLimits()
private static void createTestData() throws IOException, InterruptedException
IOException
InterruptedException
public void testSingleBlock() throws IOException
IOException
public void testCheckLimitAfterFilterRowKey() throws IOException
IOException
public void testCheckLimitAfterFilteringRowCellsDueToFilterRow() throws IOException
IOException
public void testCheckLimitAfterFilteringCell() throws IOException
IOException
public void testCheckLimitAfterFilteringRowCells() throws IOException
IOException
public void testSeekNextUsingHint() throws IOException
IOException
private org.apache.hadoop.hbase.client.Scan getBaseScan()
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.