public class TestMetaTableAccessor extends Object
org.apache.hadoop.hbase.MetaTableAccessor.| Modifier and Type | Class and Description |
|---|---|
static class |
TestMetaTableAccessor.SpyingRpcScheduler |
static class |
TestMetaTableAccessor.SpyingRpcSchedulerFactory |
| Constructor and Description |
|---|
TestMetaTableAccessor() |
| Modifier and Type | Method and Description |
|---|---|
static void |
afterClass() |
static void |
assertEmptyMetaLocation(Table meta,
byte[] row,
int replicaId) |
static void |
assertMetaLocation(Table meta,
byte[] row,
ServerName serverName,
long seqNum,
int replicaId,
boolean checkSeqNum) |
static void |
beforeClass() |
void |
testGetRegion() |
void |
testGetRegionsCatalogTables() |
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 |
testMetaUpdatesGoToPriorityQueue() |
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 |
testScanMetaForTable() |
void |
testTableExists() |
public void testRetrying()
throws IOException,
InterruptedException
MetaTableAccessor#getRegion(Connection, byte[]) and a write
against hbase:meta while its hosted server is restarted to prove our retrying
works.IOExceptionInterruptedExceptionpublic void testGetRegionsCatalogTables()
throws IOException,
InterruptedException
IOExceptionInterruptedExceptionpublic void testTableExists()
throws IOException
IOExceptionpublic void testGetRegion()
throws IOException,
InterruptedException
IOExceptionInterruptedExceptionpublic void testScanMetaForTable()
throws IOException,
InterruptedException
IOExceptionInterruptedExceptionpublic void testParseReplicaIdFromServerColumn()
public void testMetaReaderGetColumnMethods()
public void testMetaLocationsForRegionReplicas()
throws IOException
IOExceptionpublic static void assertMetaLocation(Table meta,
byte[] row,
ServerName serverName,
long seqNum,
int replicaId,
boolean checkSeqNum)
throws IOException
IOExceptionpublic static void assertEmptyMetaLocation(Table meta,
byte[] row,
int replicaId)
throws IOException
IOExceptionpublic void testMetaLocationForRegionReplicasIsAddedAtTableCreation()
throws IOException
IOExceptionpublic void testMetaLocationForRegionReplicasIsAddedAtRegionSplit()
throws IOException
IOExceptionpublic void testMetaLocationForRegionReplicasIsAddedAtRegionMerge()
throws IOException
IOExceptionpublic void testMastersSystemTimeIsUsedInUpdateLocations()
throws IOException
IOExceptionpublic void testMastersSystemTimeIsUsedInMergeRegions()
throws IOException
IOException