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.IOException
InterruptedException
public void testGetRegionsCatalogTables() throws IOException, InterruptedException
IOException
InterruptedException
public void testTableExists() throws IOException
IOException
public void testGetRegion() throws IOException, InterruptedException
IOException
InterruptedException
public void testScanMetaForTable() throws IOException, InterruptedException
IOException
InterruptedException
public void testParseReplicaIdFromServerColumn()
public void testMetaReaderGetColumnMethods()
public void testMetaLocationsForRegionReplicas() throws IOException
IOException
public static void assertMetaLocation(Table meta, byte[] row, ServerName serverName, long seqNum, int replicaId, boolean checkSeqNum) throws IOException
IOException
public static void assertEmptyMetaLocation(Table meta, byte[] row, int replicaId) throws IOException
IOException
public void testMetaLocationForRegionReplicasIsAddedAtTableCreation() throws IOException
IOException
public void testMetaLocationForRegionReplicasIsAddedAtRegionSplit() throws IOException
IOException
public void testMetaLocationForRegionReplicasIsAddedAtRegionMerge() throws IOException
IOException
public void testMastersSystemTimeIsUsedInUpdateLocations() throws IOException
IOException
public void testMastersSystemTimeIsUsedInMergeRegions() throws IOException
IOException