org.apache.hadoop.hbase.replication

Class TestReplicationSource

java.lang.Object

org.apache.hadoop.hbase.replication.TestReplicationSource

public class TestReplicationSource
extends Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	TestReplicationSource.ShutdownDelayRegionServer Regionserver implementation that adds a delay on the graceful shutdown.

Field Summary

Fields

Modifier and Type	Field and Description
static HBaseClassTestRule	CLASS_RULE

Constructor Summary

Constructors

Constructor and Description
TestReplicationSource()

Method Summary

Modifier and Type	Method and Description
static void	setUpBeforeClass()
static void	tearDownAfterClass()
void	testLogMoving() Sanity check that we can move logs around while we are reading from them.
void	testServerShutdownRecoveredQueue() Tests that recovered queues are preserved on a regionserver shutdown.
void	testTerminateTimeout() Tests that ReplicationSource.terminate(String) will timeout properly

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

Constructor Detail

TestReplicationSource

public TestReplicationSource()

Method Detail

setUpBeforeClass

public static void setUpBeforeClass()
                             throws Exception

Throws:

Exception

tearDownAfterClass

public static void tearDownAfterClass()
                               throws Exception

Throws:

Exception

testLogMoving

public void testLogMoving()
                   throws Exception

Sanity check that we can move logs around while we are reading from them. Should this test fail, ReplicationSource would have a hard time reading logs that are being archived.

Throws:

Exception

testTerminateTimeout

public void testTerminateTimeout()
                          throws Exception

Tests that ReplicationSource.terminate(String) will timeout properly

Throws:

Exception

testServerShutdownRecoveredQueue

public void testServerShutdownRecoveredQueue()
                                      throws Exception

Tests that recovered queues are preserved on a regionserver shutdown. See HBASE-18192

Throws:

Exception