org.apache.hadoop.hbase

Class TestMetaTableAccessor

java.lang.Object

org.apache.hadoop.hbase.TestMetaTableAccessor

public class TestMetaTableAccessor
extends Object

Test MetaTableAccessor.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
(package private) static class	TestMetaTableAccessor.MetaTask Thread that runs a MetaTableAccessor task until asked stop.
static class	TestMetaTableAccessor.SpyingRpcScheduler
static class	TestMetaTableAccessor.SpyingRpcSchedulerFactory

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.hbase.client.Connection	connection
private static org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static HBaseTestingUtility	UTIL

Constructor Summary

Constructors

Constructor and Description
TestMetaTableAccessor()

Method Summary

Modifier and Type	Method and Description
static void	afterClass()
static void	assertEmptyMetaLocation(org.apache.hadoop.hbase.client.Table meta, byte[] row, int replicaId)
static void	assertMetaLocation(org.apache.hadoop.hbase.client.Table meta, byte[] row, org.apache.hadoop.hbase.ServerName serverName, long seqNum, int replicaId, boolean checkSeqNum)
static void	beforeClass()
private Map<org.apache.hadoop.hbase.client.RegionInfo,Long>	getMapOfRegionsToSeqNum(org.apache.hadoop.hbase.client.RegionInfo... regions)
void	testAddMergeRegions()
void	testEmptyMetaDaughterLocationDuringSplit()
void	testGetMergeRegions() Test for HBASE-23044.
void	testGetRegion()
private static void	testGetRegion(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.client.RegionInfo region)
private static List<org.apache.hadoop.hbase.client.RegionInfo>	testGettingTableRegions(org.apache.hadoop.hbase.client.Connection connection, org.apache.hadoop.hbase.TableName name, int regionCount)
void	testIsMetaWhenAllHealthy()
void	testIsMetaWhenMetaGoesOffline()
void	testMastersSystemTimeIsUsedInMergeRegions()
void	testMastersSystemTimeIsUsedInUpdateLocations() Tests whether maximum of masters system time versus RSs local system time is used
void	testMetaLocationForRegionReplicasIsAddedAtRegionMerge()
void	testMetaLocationForRegionReplicasIsAddedAtRegionSplit()
void	testMetaLocationForRegionReplicasIsAddedAtTableCreation()
void	testMetaLocationsForRegionReplicas()
void	testMetaReaderGetColumnMethods()
void	testMetaScanner()
void	testMetaUpdatesGoToPriorityQueue()
void	testParseRegionInfoFromRegionName() The info we can get from the regionName is: table name, start key, regionId, replicaId.
void	testParseReplicaIdFromServerColumn()
void	testRetrying() Does MetaTableAccessor.getRegion(Connection, byte[]) and a write against hbase:meta while its hosted server is restarted to prove our retrying works.
void	testScanByRegionEncodedNameExistingRegion()
void	testScanByRegionEncodedNameNonExistingRegion()
void	testScanMetaForTable()

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 static final HBaseTestingUtility UTIL

connection

private static org.apache.hadoop.hbase.client.Connection connection

name

public org.junit.rules.TestName name

Constructor Detail

TestMetaTableAccessor

public TestMetaTableAccessor()

Method Detail

beforeClass

public static void beforeClass()
                        throws Exception

Throws:

Exception

afterClass

public static void afterClass()
                       throws Exception

Throws:

Exception

testGetMergeRegions

public void testGetMergeRegions()
                         throws Exception

Test for HBASE-23044.

Throws:

Exception

testAddMergeRegions

public void testAddMergeRegions()
                         throws IOException

Throws:

IOException

testIsMetaWhenAllHealthy

public void testIsMetaWhenAllHealthy()
                              throws InterruptedException

Throws:

InterruptedException

testIsMetaWhenMetaGoesOffline

public void testIsMetaWhenMetaGoesOffline()
                                   throws InterruptedException

Throws:

InterruptedException

testRetrying

public void testRetrying()
                  throws IOException,
                         InterruptedException

Does MetaTableAccessor.getRegion(Connection, byte[]) and a write against hbase:meta while its hosted server is restarted to prove our retrying works.

Throws:

IOException

InterruptedException

testGetRegion

public void testGetRegion()
                   throws IOException,
                          InterruptedException

Throws:

IOException

InterruptedException

testScanMetaForTable

public void testScanMetaForTable()
                          throws IOException,
                                 InterruptedException

Throws:

IOException

InterruptedException

testGettingTableRegions

private static List<org.apache.hadoop.hbase.client.RegionInfo> testGettingTableRegions(org.apache.hadoop.hbase.client.Connection connection,
                                                                                       org.apache.hadoop.hbase.TableName name,
                                                                                       int regionCount)
                                                                                throws IOException,
                                                                                       InterruptedException

Throws:

IOException

InterruptedException

testGetRegion

private static void testGetRegion(org.apache.hadoop.hbase.client.Connection connection,
                                  org.apache.hadoop.hbase.client.RegionInfo region)
                           throws IOException,
                                  InterruptedException

Throws:

IOException

InterruptedException

testParseReplicaIdFromServerColumn

public void testParseReplicaIdFromServerColumn()

testParseRegionInfoFromRegionName

public void testParseRegionInfoFromRegionName()
                                       throws IOException

The info we can get from the regionName is: table name, start key, regionId, replicaId.

Throws:

IOException

testMetaReaderGetColumnMethods

public void testMetaReaderGetColumnMethods()

testMetaLocationsForRegionReplicas

public void testMetaLocationsForRegionReplicas()
                                        throws IOException

Throws:

IOException

assertMetaLocation

public static void assertMetaLocation(org.apache.hadoop.hbase.client.Table meta,
                                      byte[] row,
                                      org.apache.hadoop.hbase.ServerName serverName,
                                      long seqNum,
                                      int replicaId,
                                      boolean checkSeqNum)
                               throws IOException

Throws:

IOException

assertEmptyMetaLocation

public static void assertEmptyMetaLocation(org.apache.hadoop.hbase.client.Table meta,
                                           byte[] row,
                                           int replicaId)
                                    throws IOException

Throws:

IOException

testMetaLocationForRegionReplicasIsAddedAtTableCreation

public void testMetaLocationForRegionReplicasIsAddedAtTableCreation()
                                                             throws IOException

Throws:

IOException

testMetaLocationForRegionReplicasIsAddedAtRegionSplit

public void testMetaLocationForRegionReplicasIsAddedAtRegionSplit()
                                                           throws IOException

Throws:

IOException

testMetaLocationForRegionReplicasIsAddedAtRegionMerge

public void testMetaLocationForRegionReplicasIsAddedAtRegionMerge()
                                                           throws IOException

Throws:

IOException

getMapOfRegionsToSeqNum

private Map<org.apache.hadoop.hbase.client.RegionInfo,Long> getMapOfRegionsToSeqNum(org.apache.hadoop.hbase.client.RegionInfo... regions)

testMetaScanner

public void testMetaScanner()
                     throws Exception

Throws:

Exception

testMastersSystemTimeIsUsedInUpdateLocations

public void testMastersSystemTimeIsUsedInUpdateLocations()
                                                  throws IOException

Tests whether maximum of masters system time versus RSs local system time is used

Throws:

IOException

testMastersSystemTimeIsUsedInMergeRegions

public void testMastersSystemTimeIsUsedInMergeRegions()
                                               throws IOException

Throws:

IOException

testMetaUpdatesGoToPriorityQueue

public void testMetaUpdatesGoToPriorityQueue()
                                      throws Exception

Throws:

Exception

testEmptyMetaDaughterLocationDuringSplit

public void testEmptyMetaDaughterLocationDuringSplit()
                                              throws IOException

Throws:

IOException

testScanByRegionEncodedNameExistingRegion

public void testScanByRegionEncodedNameExistingRegion()
                                               throws Exception

Throws:

Exception

testScanByRegionEncodedNameNonExistingRegion

public void testScanByRegionEncodedNameNonExistingRegion()
                                                  throws Exception

Throws:

Exception