public class TestTableSnapshotInputFormat extends TableSnapshotInputFormatTestBase
Modifier and Type | Class and Description |
---|---|
static class |
TestTableSnapshotInputFormat.TestTableSnapshotReducer |
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
TestName |
name |
FAMILIES, fs, NUM_REGION_SERVERS, rootDir, UTIL
Constructor and Description |
---|
TestTableSnapshotInputFormat() |
Modifier and Type | Method and Description |
---|---|
static void |
doTestWithMapReduce(HBaseTestingUtility util,
TableName tableName,
java.lang.String snapshotName,
byte[] startRow,
byte[] endRow,
Path tableDir,
int numRegions,
int numSplitsPerRegion,
int expectedNumSplits,
boolean shutdownCluster) |
protected byte[] |
getEndRow() |
protected byte[] |
getStartRow() |
void |
testInitTableSnapshotMapperJobConfig() |
void |
testRestoreSnapshotDoesNotCreateBackRefLinksInit(TableName tableName,
java.lang.String snapshotName,
Path tmpTableDir) |
void |
testWithMapReduceAndOfflineHBaseMultiRegion() |
protected void |
testWithMapReduceImpl(HBaseTestingUtility util,
TableName tableName,
java.lang.String snapshotName,
Path tableDir,
int numRegions,
int numSplitsPerRegion,
int expectedNumSplits,
boolean shutdownCluster) |
void |
testWithMapReduceMultiRegion() |
protected void |
testWithMockedMapReduce(HBaseTestingUtility util,
java.lang.String snapshotName,
int numRegions,
int numSplitsPerRegion,
int expectedNumSplits,
boolean setLocalityEnabledTo) |
void |
testWithMockedMapReduceMultiRegion() |
createTableAndSnapshot, setupCluster, tearDownCluster, testRestoreSnapshotDoesNotCreateBackRefLinks, testWithMapReduce, testWithMapReduceMultipleMappersPerRegion, testWithMapReduceSingleRegion, testWithMockedMapReduceSingleRegion, verifyRowFromMap
protected byte[] getStartRow()
getStartRow
in class TableSnapshotInputFormatTestBase
protected byte[] getEndRow()
getEndRow
in class TableSnapshotInputFormatTestBase
public void testInitTableSnapshotMapperJobConfig() throws java.lang.Exception
java.lang.Exception
public void testWithMockedMapReduceMultiRegion() throws java.lang.Exception
testWithMockedMapReduceMultiRegion
in class TableSnapshotInputFormatTestBase
java.lang.Exception
public void testWithMapReduceMultiRegion() throws java.lang.Exception
testWithMapReduceMultiRegion
in class TableSnapshotInputFormatTestBase
java.lang.Exception
public void testWithMapReduceAndOfflineHBaseMultiRegion() throws java.lang.Exception
testWithMapReduceAndOfflineHBaseMultiRegion
in class TableSnapshotInputFormatTestBase
java.lang.Exception
public void testRestoreSnapshotDoesNotCreateBackRefLinksInit(TableName tableName, java.lang.String snapshotName, Path tmpTableDir) throws java.lang.Exception
testRestoreSnapshotDoesNotCreateBackRefLinksInit
in class TableSnapshotInputFormatTestBase
java.lang.Exception
protected void testWithMockedMapReduce(HBaseTestingUtility util, java.lang.String snapshotName, int numRegions, int numSplitsPerRegion, int expectedNumSplits, boolean setLocalityEnabledTo) throws java.lang.Exception
testWithMockedMapReduce
in class TableSnapshotInputFormatTestBase
java.lang.Exception
protected void testWithMapReduceImpl(HBaseTestingUtility util, TableName tableName, java.lang.String snapshotName, Path tableDir, int numRegions, int numSplitsPerRegion, int expectedNumSplits, boolean shutdownCluster) throws java.lang.Exception
testWithMapReduceImpl
in class TableSnapshotInputFormatTestBase
java.lang.Exception
public static void doTestWithMapReduce(HBaseTestingUtility util, TableName tableName, java.lang.String snapshotName, byte[] startRow, byte[] endRow, Path tableDir, int numRegions, int numSplitsPerRegion, int expectedNumSplits, boolean shutdownCluster) throws java.lang.Exception
java.lang.Exception