Package org.apache.hadoop.hbase.client

Class TestTableSnapshotScanner

java.lang.Object

org.apache.hadoop.hbase.client.TestTableSnapshotScanner

Direct Known Subclasses:

TestTableSnapshotScannerWithSFT

@Tag("org.apache.hadoop.hbase.testclassification.LargeTests") @Tag("org.apache.hadoop.hbase.testclassification.ClientTests")
public class TestTableSnapshotScanner
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static byte[]	bbb
private boolean	clusterUp
private static final byte[][]	FAMILIES
private org.apache.hadoop.fs.FileSystem	fs
private static final org.slf4j.Logger	LOG
private String	methodName
private static final int	NUM_REGION_SERVERS
private org.apache.hadoop.fs.Path	rootDir
private final HBaseTestingUtil	UTIL
static byte[]	yyy

Constructor Summary

Constructors

Constructor	Description
TestTableSnapshotScanner()

Method Summary

Modifier and Type	Method	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)
private org.apache.hadoop.hbase.client.metrics.ScanMetrics	createTableSnapshotScannerAndGetScanMetrics(boolean enableScanMetrics, boolean enableScanMetricsByRegion, byte[] endKey)
void	setupCluster(org.junit.jupiter.api.TestInfo testInfo)
protected void	setupConf(org.apache.hadoop.conf.Configuration conf)
void	tearDownCluster()
void	testDeleteTableWithMergedRegions()
void	testMergeRegion()
void	testNoDuplicateResultsWhenSplitting()
void	testScanLimit()
void	testScanMetricsByRegionForMultiRegion()
void	testScanMetricsByRegionForSingleRegion()
void	testScanMetricsDisabled()
void	testScanMetricsWithScanMetricsByRegionDisabled()
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)

Methods inherited from class java.lang.Object

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

Field Details

LOG

private static final org.slf4j.Logger LOG

UTIL

private final HBaseTestingUtil UTIL

NUM_REGION_SERVERS

private static final int NUM_REGION_SERVERS

See Also:

• Constant Field Values

FAMILIES

private static final byte[][] FAMILIES

bbb

public static byte[] bbb

yyy

public static byte[] yyy

fs

private org.apache.hadoop.fs.FileSystem fs

rootDir

private org.apache.hadoop.fs.Path rootDir

clusterUp

private boolean clusterUp

methodName

private String methodName

Constructor Details

TestTableSnapshotScanner

public TestTableSnapshotScanner()

Method Details

blockUntilSplitFinished

public static void blockUntilSplitFinished(HBaseTestingUtil util,
 org.apache.hadoop.hbase.TableName tableName,
 int expectedRegionSize)
                                    throws Exception

Throws:

Exception

setupCluster

@BeforeEach
public void setupCluster(org.junit.jupiter.api.TestInfo testInfo)
                  throws Exception

Throws:

Exception

tearDownCluster

@AfterEach
public void tearDownCluster()
                     throws Exception

Throws:

Exception

setupConf

protected void setupConf(org.apache.hadoop.conf.Configuration conf)

createTableAndSnapshot

public static void createTableAndSnapshot(HBaseTestingUtil util,
 org.apache.hadoop.hbase.TableName tableName,
 String snapshotName,
 int numRegions)
                                   throws Exception

Throws:

Exception

testNoDuplicateResultsWhenSplitting

@Test
public void testNoDuplicateResultsWhenSplitting()
                                         throws Exception

Throws:

Exception

testScanLimit

@Test
public void testScanLimit()
                   throws Exception

Throws:

Exception

testWithSingleRegion

@Test
public void testWithSingleRegion()
                          throws Exception

Throws:

Exception

testWithMultiRegion

@Test
public void testWithMultiRegion()
                         throws Exception

Throws:

Exception

testWithOfflineHBaseMultiRegion

@Test
public void testWithOfflineHBaseMultiRegion()
                                     throws Exception

Throws:

Exception

createTableSnapshotScannerAndGetScanMetrics

private org.apache.hadoop.hbase.client.metrics.ScanMetrics createTableSnapshotScannerAndGetScanMetrics(boolean enableScanMetrics,
 boolean enableScanMetricsByRegion,
 byte[] endKey)
                                                                                                throws Exception

Throws:

Exception

testScanMetricsDisabled

@Test
public void testScanMetricsDisabled()
                             throws Exception

Throws:

Exception

testScanMetricsWithScanMetricsByRegionDisabled

@Test
public void testScanMetricsWithScanMetricsByRegionDisabled()
                                                    throws Exception

Throws:

Exception

testScanMetricsByRegionForSingleRegion

@Test
public void testScanMetricsByRegionForSingleRegion()
                                            throws Exception

Throws:

Exception

testScanMetricsByRegionForMultiRegion

@Test
public void testScanMetricsByRegionForMultiRegion()
                                           throws Exception

Throws:

Exception

testScannerWithRestoreScanner

@Test
public void testScannerWithRestoreScanner()
                                   throws Exception

Throws:

Exception

testScanner

private void testScanner(HBaseTestingUtil util,
 String snapshotName,
 int numRegions,
 boolean shutdownCluster)
                  throws Exception

Throws:

Exception

verifyScanner

private void verifyScanner(org.apache.hadoop.hbase.client.ResultScanner scanner,
 byte[] startRow,
 byte[] stopRow)
                    throws IOException,
InterruptedException

Throws:

IOException

InterruptedException

verifyRow

private static void verifyRow(org.apache.hadoop.hbase.client.Result result)
                       throws IOException

Throws:

IOException

testMergeRegion

@Test
public void testMergeRegion()
                     throws Exception

Throws:

Exception

testDeleteTableWithMergedRegions

@Test
public void testDeleteTableWithMergedRegions()
                                      throws Exception

Throws:

Exception

traverseAndSetFileTime

private void traverseAndSetFileTime(org.apache.hadoop.fs.Path path,
 long time)
                             throws IOException

Throws:

IOException