public class TestTableSnapshotScanner extends Object
Modifier and Type | Field and Description |
---|---|
static byte[] |
bbb |
static HBaseClassTestRule |
CLASS_RULE |
private boolean |
clusterUp |
private static byte[][] |
FAMILIES |
private org.apache.hadoop.fs.FileSystem |
fs |
private static org.slf4j.Logger |
LOG |
org.junit.rules.TestName |
name |
private static int |
NUM_REGION_SERVERS |
private org.apache.hadoop.fs.Path |
rootDir |
private HBaseTestingUtil |
UTIL |
static byte[] |
yyy |
Constructor and Description |
---|
TestTableSnapshotScanner() |
Modifier and Type | Method and Description |
---|---|
static void |
blockUntilSplitFinished(HBaseTestingUtil util,
org.apache.hadoop.hbase.TableName tableName,
int expectedRegionSize) |
static void |
createTableAndSnapshot(HBaseTestingUtil util,
org.apache.hadoop.hbase.TableName tableName,
String snapshotName,
int numRegions) |
void |
setupCluster() |
protected void |
setupConf(org.apache.hadoop.conf.Configuration conf) |
void |
tearDownCluster() |
void |
testDeleteTableWithMergedRegions() |
void |
testMergeRegion() |
void |
testNoDuplicateResultsWhenSplitting() |
void |
testScanLimit() |
private void |
testScanner(HBaseTestingUtil util,
String snapshotName,
int numRegions,
boolean shutdownCluster) |
void |
testScannerWithRestoreScanner() |
void |
testWithMultiRegion() |
void |
testWithOfflineHBaseMultiRegion() |
void |
testWithSingleRegion() |
private void |
traverseAndSetFileTime(org.apache.hadoop.fs.Path path,
long time) |
private static void |
verifyRow(org.apache.hadoop.hbase.client.Result result) |
private void |
verifyScanner(org.apache.hadoop.hbase.client.ResultScanner scanner,
byte[] startRow,
byte[] stopRow) |
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private final HBaseTestingUtil UTIL
private static final int NUM_REGION_SERVERS
private static final byte[][] FAMILIES
public static byte[] bbb
public static byte[] yyy
private org.apache.hadoop.fs.FileSystem fs
private org.apache.hadoop.fs.Path rootDir
private boolean clusterUp
public org.junit.rules.TestName name
public TestTableSnapshotScanner()
public static void blockUntilSplitFinished(HBaseTestingUtil util, org.apache.hadoop.hbase.TableName tableName, int expectedRegionSize) throws Exception
Exception
public void setupCluster() throws Exception
Exception
public void tearDownCluster() throws Exception
Exception
protected void setupConf(org.apache.hadoop.conf.Configuration conf)
public static void createTableAndSnapshot(HBaseTestingUtil util, org.apache.hadoop.hbase.TableName tableName, String snapshotName, int numRegions) throws Exception
Exception
public void testNoDuplicateResultsWhenSplitting() throws Exception
Exception
public void testScanLimit() throws Exception
Exception
public void testWithSingleRegion() throws Exception
Exception
public void testWithMultiRegion() throws Exception
Exception
public void testWithOfflineHBaseMultiRegion() throws Exception
Exception
public void testScannerWithRestoreScanner() throws Exception
Exception
private void testScanner(HBaseTestingUtil util, String snapshotName, int numRegions, boolean shutdownCluster) throws Exception
Exception
private void verifyScanner(org.apache.hadoop.hbase.client.ResultScanner scanner, byte[] startRow, byte[] stopRow) throws IOException, InterruptedException
IOException
InterruptedException
private static void verifyRow(org.apache.hadoop.hbase.client.Result result) throws IOException
IOException
public void testMergeRegion() throws Exception
Exception
public void testDeleteTableWithMergedRegions() throws Exception
Exception
private void traverseAndSetFileTime(org.apache.hadoop.fs.Path path, long time) throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.