org.apache.hadoop.hbase.client

Class TestTableSnapshotScanner

java.lang.Object

org.apache.hadoop.hbase.client.TestTableSnapshotScanner

public class TestTableSnapshotScanner
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static byte[]	bbb
static HBaseClassTestRule	CLASS_RULE
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 Summary

Constructors

Constructor and Description
TestTableSnapshotScanner()

Method Summary

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()
private static void	setupConf(org.apache.hadoop.conf.Configuration conf)
void	tearDown()
void	tearDownCluster()
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)

Methods inherited from class java.lang.Object

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

Field Detail

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

LOG

private static final org.slf4j.Logger LOG

UTIL

private final HBaseTestingUtility 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

name

public org.junit.rules.TestName name

Constructor Detail

TestTableSnapshotScanner

public TestTableSnapshotScanner()

Method Detail

blockUntilSplitFinished

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

Throws:

Exception

setupCluster

public void setupCluster()
                  throws Exception

Throws:

Exception

tearDownCluster

public void tearDownCluster()
                     throws Exception

Throws:

Exception

setupConf

private static void setupConf(org.apache.hadoop.conf.Configuration conf)

tearDown

public void tearDown()
              throws Exception

Throws:

Exception

createTableAndSnapshot

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

Throws:

Exception

testNoDuplicateResultsWhenSplitting

public void testNoDuplicateResultsWhenSplitting()
                                         throws Exception

Throws:

Exception

testScanLimit

public void testScanLimit()
                   throws Exception

Throws:

Exception

testWithSingleRegion

public void testWithSingleRegion()
                          throws Exception

Throws:

Exception

testWithMultiRegion

public void testWithMultiRegion()
                         throws Exception

Throws:

Exception

testWithOfflineHBaseMultiRegion

public void testWithOfflineHBaseMultiRegion()
                                     throws Exception

Throws:

Exception

testScannerWithRestoreScanner

public void testScannerWithRestoreScanner()
                                   throws Exception

Throws:

Exception

testScanner

private void testScanner(HBaseTestingUtility 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

public void testMergeRegion()
                     throws Exception

Throws:

Exception

traverseAndSetFileTime

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

Throws:

IOException