org.apache.hadoop.hbase

Class TestMetaTableAccessor

java.lang.Object

org.apache.hadoop.hbase.TestMetaTableAccessor

public class TestMetaTableAccessor
extends java.lang.Object

Test org.apache.hadoop.hbase.MetaTableAccessor.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestMetaTableAccessor.SpyingRpcScheduler
static class	TestMetaTableAccessor.SpyingRpcSchedulerFactory

Constructor Summary

Constructors

Constructor and Description
TestMetaTableAccessor()

Method Summary

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()

Methods inherited from class java.lang.Object

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

Constructor Detail

TestMetaTableAccessor

public TestMetaTableAccessor()

Method Detail

beforeClass

public static void beforeClass()
                        throws java.lang.Exception

Throws:

java.lang.Exception

afterClass

public static void afterClass()
                       throws java.lang.Exception

Throws:

java.lang.Exception

testRetrying

public void testRetrying()
                  throws java.io.IOException,
                         java.lang.InterruptedException

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

Throws:

java.io.IOException

java.lang.InterruptedException

testGetRegionsCatalogTables

public void testGetRegionsCatalogTables()
                                 throws java.io.IOException,
                                        java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

testTableExists

public void testTableExists()
                     throws java.io.IOException

Throws:

java.io.IOException

testGetRegion

public void testGetRegion()
                   throws java.io.IOException,
                          java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

testScanMetaForTable

public void testScanMetaForTable()
                          throws java.io.IOException,
                                 java.lang.InterruptedException

Throws:

java.io.IOException

java.lang.InterruptedException

testParseReplicaIdFromServerColumn

public void testParseReplicaIdFromServerColumn()

testMetaReaderGetColumnMethods

public void testMetaReaderGetColumnMethods()

testMetaLocationsForRegionReplicas

public void testMetaLocationsForRegionReplicas()
                                        throws java.io.IOException

Throws:

java.io.IOException

assertMetaLocation

public static void assertMetaLocation(Table meta,
                                      byte[] row,
                                      ServerName serverName,
                                      long seqNum,
                                      int replicaId,
                                      boolean checkSeqNum)
                               throws java.io.IOException

Throws:

java.io.IOException

assertEmptyMetaLocation

public static void assertEmptyMetaLocation(Table meta,
                                           byte[] row,
                                           int replicaId)
                                    throws java.io.IOException

Throws:

java.io.IOException

testMetaLocationForRegionReplicasIsAddedAtTableCreation

public void testMetaLocationForRegionReplicasIsAddedAtTableCreation()
                                                             throws java.io.IOException

Throws:

java.io.IOException

testMetaLocationForRegionReplicasIsAddedAtRegionSplit

public void testMetaLocationForRegionReplicasIsAddedAtRegionSplit()
                                                           throws java.io.IOException

Throws:

java.io.IOException

testMetaLocationForRegionReplicasIsAddedAtRegionMerge

public void testMetaLocationForRegionReplicasIsAddedAtRegionMerge()
                                                           throws java.io.IOException

Throws:

java.io.IOException

testMastersSystemTimeIsUsedInUpdateLocations

public void testMastersSystemTimeIsUsedInUpdateLocations()
                                                  throws java.io.IOException

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

Throws:

java.io.IOException

testMastersSystemTimeIsUsedInMergeRegions

public void testMastersSystemTimeIsUsedInMergeRegions()
                                               throws java.io.IOException

Throws:

java.io.IOException

testMetaUpdatesGoToPriorityQueue

public void testMetaUpdatesGoToPriorityQueue()
                                      throws java.lang.Exception

Throws:

java.lang.Exception