Package org.apache.hadoop.hbase.replication

Class TestZKReplicationQueueStorage

java.lang.Object

org.apache.hadoop.hbase.replication.TestZKReplicationQueueStorage

public class TestZKReplicationQueueStorage
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private static org.apache.hadoop.hbase.replication.ZKReplicationQueueStorage	STORAGE
private static final HBaseZKTestingUtility	UTIL

Constructor Summary

Constructors

Constructor	Description
TestZKReplicationQueueStorage()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.replication.ZKReplicationQueueStorage	createWithUnstableVersion()
private String	getFileName(String base, int i)
private org.apache.hadoop.hbase.ServerName	getServerName(int i)
static void	setUp()
static void	tearDown()
void	tearDownAfterTest()
void	testAddRemoveLog()
void	testClaimQueueChangeCversion()
void	testGetAllHFileRefsCversionChange()
void	testGetAllWALsCversionChange()
void	testRegionsZNodeLayout()
void	testRemoveAllLastPushedSeqIdsForPeer()
void	testReplicator()
void	testSetWALPositionBadVersion()

Methods inherited from class java.lang.Object

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

Field Details

CLASS_RULE

public static final HBaseClassTestRule CLASS_RULE

UTIL

private static final HBaseZKTestingUtility UTIL

STORAGE

private static org.apache.hadoop.hbase.replication.ZKReplicationQueueStorage STORAGE

Constructor Details

TestZKReplicationQueueStorage

public TestZKReplicationQueueStorage()

Method Details

setUp

public static void setUp()
                  throws Exception

Throws:

Exception

tearDown

public static void tearDown()
                     throws IOException

Throws:

IOException

tearDownAfterTest

public void tearDownAfterTest()
                       throws org.apache.hadoop.hbase.replication.ReplicationException,
org.apache.zookeeper.KeeperException,
IOException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

org.apache.zookeeper.KeeperException

IOException

getServerName

private org.apache.hadoop.hbase.ServerName getServerName(int i)

testReplicator

public void testReplicator()
                    throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

getFileName

private String getFileName(String base,
 int i)

testAddRemoveLog

public void testAddRemoveLog()
                      throws org.apache.hadoop.hbase.replication.ReplicationException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

testClaimQueueChangeCversion

public void testClaimQueueChangeCversion()
                                  throws org.apache.hadoop.hbase.replication.ReplicationException,
org.apache.zookeeper.KeeperException

Throws:

org.apache.hadoop.hbase.replication.ReplicationException

org.apache.zookeeper.KeeperException

createWithUnstableVersion

private org.apache.hadoop.hbase.replication.ZKReplicationQueueStorage createWithUnstableVersion()
                                                                                         throws IOException

Throws:

IOException

testGetAllWALsCversionChange

public void testGetAllWALsCversionChange()
                                  throws IOException,
org.apache.hadoop.hbase.replication.ReplicationException

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testGetAllHFileRefsCversionChange

public void testGetAllHFileRefsCversionChange()
                                       throws IOException,
org.apache.hadoop.hbase.replication.ReplicationException

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testSetWALPositionBadVersion

public void testSetWALPositionBadVersion()
                                  throws IOException,
org.apache.hadoop.hbase.replication.ReplicationException

Throws:

IOException

org.apache.hadoop.hbase.replication.ReplicationException

testRegionsZNodeLayout

public void testRegionsZNodeLayout()
                            throws Exception

Throws:

Exception

testRemoveAllLastPushedSeqIdsForPeer

public void testRemoveAllLastPushedSeqIdsForPeer()
                                          throws Exception

Throws:

Exception