Package org.apache.hadoop.hbase.regionserver

Class TestStoreFileRefresherChore

java.lang.Object

org.apache.hadoop.hbase.regionserver.TestStoreFileRefresherChore

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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestStoreFileRefresherChore.FailingHRegionFileSystem
(package private) static class	TestStoreFileRefresherChore.StaleStorefileRefresherChore

Field Summary

Fields

Modifier and Type	Field	Description
private String	methodName
private HBaseTestingUtil	TEST_UTIL
private org.apache.hadoop.fs.Path	testDir

Constructor Summary

Constructors

Constructor	Description
TestStoreFileRefresherChore()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.client.TableDescriptor	getTableDesc(org.apache.hadoop.hbase.TableName tableName, int regionReplication, boolean readOnly, String trackerName, byte[]... families)
private org.apache.hadoop.hbase.client.TableDescriptor	getTableDesc(org.apache.hadoop.hbase.TableName tableName, int regionReplication, String trackerName, byte[]... families)
private org.apache.hadoop.hbase.regionserver.HRegion	initHRegion(org.apache.hadoop.hbase.client.TableDescriptor htd, byte[] startKey, byte[] stopKey, int replicaId)
private void	putData(org.apache.hadoop.hbase.regionserver.Region region, int startRow, int numRows, byte[] qf, byte[]... families)
void	setUp(org.junit.jupiter.api.TestInfo testInfo)
void	testIsStale()
void	testRefreshReadOnlyTable()
private void	verifyData(org.apache.hadoop.hbase.regionserver.Region newReg, int startRow, int numRows, byte[] qf, byte[]... families)
private void	verifyDataExpectFail(org.apache.hadoop.hbase.regionserver.Region newReg, int startRow, int numRows, byte[] qf, byte[]... families)

Methods inherited from class java.lang.Object

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

Field Details

TEST_UTIL

private HBaseTestingUtil TEST_UTIL

testDir

private org.apache.hadoop.fs.Path testDir

methodName

private String methodName

Constructor Details

TestStoreFileRefresherChore

public TestStoreFileRefresherChore()

Method Details

setUp

@BeforeEach
public void setUp(org.junit.jupiter.api.TestInfo testInfo)
           throws IOException

Throws:

IOException

getTableDesc

private org.apache.hadoop.hbase.client.TableDescriptor getTableDesc(org.apache.hadoop.hbase.TableName tableName,
 int regionReplication,
 String trackerName,
 byte[]... families)

getTableDesc

private org.apache.hadoop.hbase.client.TableDescriptor getTableDesc(org.apache.hadoop.hbase.TableName tableName,
 int regionReplication,
 boolean readOnly,
 String trackerName,
 byte[]... families)

initHRegion

private org.apache.hadoop.hbase.regionserver.HRegion initHRegion(org.apache.hadoop.hbase.client.TableDescriptor htd,
 byte[] startKey,
 byte[] stopKey,
 int replicaId)
                                                          throws IOException

Throws:

IOException

putData

private void putData(org.apache.hadoop.hbase.regionserver.Region region,
 int startRow,
 int numRows,
 byte[] qf,
 byte[]... families)
              throws IOException

Throws:

IOException

verifyDataExpectFail

private void verifyDataExpectFail(org.apache.hadoop.hbase.regionserver.Region newReg,
 int startRow,
 int numRows,
 byte[] qf,
 byte[]... families)
                           throws IOException

Throws:

IOException

verifyData

private void verifyData(org.apache.hadoop.hbase.regionserver.Region newReg,
 int startRow,
 int numRows,
 byte[] qf,
 byte[]... families)
                 throws IOException

Throws:

IOException

testIsStale

@Test
public void testIsStale()
                 throws IOException

Throws:

IOException

testRefreshReadOnlyTable

@Test
public void testRefreshReadOnlyTable()
                              throws IOException

Throws:

IOException