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 HBaseTestingUtility |
UTIL |
static byte[] |
yyy |
Constructor and Description |
---|
TestTableSnapshotScanner() |
Modifier and Type | Method and Description |
---|---|
static void |
blockUntilSplitFinished(HBaseTestingUtility util,
org.apache.hadoop.hbase.TableName tableName,
int expectedRegionSize) |
static void |
createTableAndSnapshot(HBaseTestingUtility 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(HBaseTestingUtility 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 HBaseTestingUtility 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(HBaseTestingUtility 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(HBaseTestingUtility 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(HBaseTestingUtility 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.