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