Package org.apache.hadoop.hbase.regionserver

Class TestSwitchToStreamRead

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestSwitchToStreamRead

@Tag("org.apache.hadoop.hbase.testclassification.RegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
public class TestSwitchToStreamRead
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	TestSwitchToStreamRead.MatchLastRowCellNextColFilter
static final class	TestSwitchToStreamRead.MatchLastRowCellNextRowFilter
static final class	TestSwitchToStreamRead.MatchLastRowFilterRowFilter
static final class	TestSwitchToStreamRead.MatchLastRowKeyFilter

Field Summary

Fields

Modifier and Type	Field	Description
private static byte[]	FAMILY
private static byte[]	QUAL
private static org.apache.hadoop.hbase.regionserver.HRegion	REGION
private static org.apache.hadoop.hbase.TableName	TABLE_NAME
private static final HBaseTestingUtil	UTIL
private static String	VALUE_PREFIX

Constructor Summary

Constructors

Constructor	Description
TestSwitchToStreamRead()

Method Summary

Modifier and Type	Method	Description
void	setUp()
void	tearDown()
void	test()
private void	testFilter(org.apache.hadoop.hbase.filter.Filter filter)
void	testFilterCellNextCol()
void	testFilterCellNextRow()
void	testFilterRow()
void	testFilterRowKey()
void	testGetFilesReadOnTrySwitchToStreamRead()	Verifies that when the store scanner switches from pread to stream read successfully, all store files that were read (including those closed during the switch) are reported by StoreScanner.getFilesRead() after close.

Methods inherited from class java.lang.Object

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

Field Details

UTIL

private static final HBaseTestingUtil UTIL

TABLE_NAME

private static org.apache.hadoop.hbase.TableName TABLE_NAME

FAMILY

private static byte[] FAMILY

QUAL

private static byte[] QUAL

VALUE_PREFIX

private static String VALUE_PREFIX

REGION

private static org.apache.hadoop.hbase.regionserver.HRegion REGION

Constructor Details

TestSwitchToStreamRead

public TestSwitchToStreamRead()

Method Details

setUp

@BeforeEach
public void setUp()
           throws IOException

Throws:

IOException

tearDown

@AfterEach
public void tearDown()
              throws IOException

Throws:

IOException

test

@Test
public void test()
          throws IOException

Throws:

IOException

testFilter

private void testFilter(org.apache.hadoop.hbase.filter.Filter filter)
                 throws IOException

Throws:

IOException

testFilterRowKey

@Disabled
@Test
public void testFilterRowKey()
                      throws IOException

Throws:

IOException

testFilterCellNextCol

@Test
public void testFilterCellNextCol()
                           throws IOException

Throws:

IOException

testFilterCellNextRow

@Test
public void testFilterCellNextRow()
                           throws IOException

Throws:

IOException

testFilterRow

@Test
public void testFilterRow()
                   throws IOException

Throws:

IOException

testGetFilesReadOnTrySwitchToStreamRead

@Test
public void testGetFilesReadOnTrySwitchToStreamRead()
                                             throws Exception

Verifies that when the store scanner switches from pread to stream read successfully, all store files that were read (including those closed during the switch) are reported by StoreScanner.getFilesRead() after close.

Throws:

Exception