public abstract class TableSnapshotInputFormatTestBase
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
protected static byte[][] |
FAMILIES |
protected FileSystem |
fs |
protected static int |
NUM_REGION_SERVERS |
protected Path |
rootDir |
protected HBaseTestingUtility |
UTIL |
Constructor and Description |
---|
TableSnapshotInputFormatTestBase() |
Modifier and Type | Method and Description |
---|---|
protected static void |
createTableAndSnapshot(HBaseTestingUtility util,
TableName tableName,
java.lang.String snapshotName,
byte[] startRow,
byte[] endRow,
int numRegions) |
protected abstract byte[] |
getEndRow() |
protected abstract byte[] |
getStartRow() |
void |
setupCluster() |
void |
tearDownCluster() |
void |
testRestoreSnapshotDoesNotCreateBackRefLinks() |
abstract void |
testRestoreSnapshotDoesNotCreateBackRefLinksInit(TableName tableName,
java.lang.String snapshotName,
Path tmpTableDir) |
protected void |
testWithMapReduce(HBaseTestingUtility util,
java.lang.String snapshotName,
int numRegions,
int numSplitsPerRegion,
int expectedNumSplits,
boolean shutdownCluster) |
void |
testWithMapReduceAndOfflineHBaseMultiRegion() |
protected abstract void |
testWithMapReduceImpl(HBaseTestingUtility util,
TableName tableName,
java.lang.String snapshotName,
Path tableDir,
int numRegions,
int numSplitsPerRegion,
int expectedNumSplits,
boolean shutdownCluster) |
void |
testWithMapReduceMultipleMappersPerRegion() |
void |
testWithMapReduceMultiRegion() |
void |
testWithMapReduceSingleRegion() |
protected abstract void |
testWithMockedMapReduce(HBaseTestingUtility util,
java.lang.String snapshotName,
int numRegions,
int numSplitsPerRegion,
int expectedNumSplits,
boolean setLocalityEnabledTo) |
void |
testWithMockedMapReduceMultiRegion() |
void |
testWithMockedMapReduceSingleRegion() |
protected static void |
verifyRowFromMap(ImmutableBytesWritable key,
Result result) |
protected final HBaseTestingUtility UTIL
protected static final int NUM_REGION_SERVERS
protected static final byte[][] FAMILIES
protected FileSystem fs
protected Path rootDir
public void setupCluster() throws java.lang.Exception
java.lang.Exception
public void tearDownCluster() throws java.lang.Exception
java.lang.Exception
protected abstract void testWithMockedMapReduce(HBaseTestingUtility util, java.lang.String snapshotName, int numRegions, int numSplitsPerRegion, int expectedNumSplits, boolean setLocalityEnabledTo) throws java.lang.Exception
java.lang.Exception
protected abstract void testWithMapReduceImpl(HBaseTestingUtility util, TableName tableName, java.lang.String snapshotName, Path tableDir, int numRegions, int numSplitsPerRegion, int expectedNumSplits, boolean shutdownCluster) throws java.lang.Exception
java.lang.Exception
protected abstract byte[] getStartRow()
protected abstract byte[] getEndRow()
public void testWithMockedMapReduceSingleRegion() throws java.lang.Exception
java.lang.Exception
public void testWithMockedMapReduceMultiRegion() throws java.lang.Exception
java.lang.Exception
public void testWithMapReduceSingleRegion() throws java.lang.Exception
java.lang.Exception
public void testWithMapReduceMultiRegion() throws java.lang.Exception
java.lang.Exception
public void testWithMapReduceMultipleMappersPerRegion() throws java.lang.Exception
java.lang.Exception
public void testWithMapReduceAndOfflineHBaseMultiRegion() throws java.lang.Exception
java.lang.Exception
public void testRestoreSnapshotDoesNotCreateBackRefLinks() throws java.lang.Exception
java.lang.Exception
public abstract void testRestoreSnapshotDoesNotCreateBackRefLinksInit(TableName tableName, java.lang.String snapshotName, Path tmpTableDir) throws java.lang.Exception
java.lang.Exception
protected void testWithMapReduce(HBaseTestingUtility util, java.lang.String snapshotName, int numRegions, int numSplitsPerRegion, int expectedNumSplits, boolean shutdownCluster) throws java.lang.Exception
java.lang.Exception
protected static void verifyRowFromMap(ImmutableBytesWritable key, Result result) throws java.io.IOException
java.io.IOException
protected static void createTableAndSnapshot(HBaseTestingUtility util, TableName tableName, java.lang.String snapshotName, byte[] startRow, byte[] endRow, int numRegions) throws java.lang.Exception
java.lang.Exception