public class TestTableReplicationQueueStorage extends Object
Modifier and Type | Field and Description |
---|---|
static HBaseClassTestRule |
CLASS_RULE |
private static org.slf4j.Logger |
LOG |
private org.apache.hadoop.hbase.replication.TableReplicationQueueStorage |
storage |
TableNameTestRule |
tableNameRule |
private static HBaseTestingUtil |
UTIL |
Constructor and Description |
---|
TestTableReplicationQueueStorage() |
Modifier and Type | Method and Description |
---|---|
private void |
addLastSequenceIdsAndHFileRefs(String peerId1,
String peerId2) |
private void |
assertGroupOffset(String wal,
long offset,
org.apache.hadoop.hbase.replication.ReplicationGroupOffset groupOffset) |
private void |
assertQueueId(String peerId,
org.apache.hadoop.hbase.ServerName serverName,
org.apache.hadoop.hbase.replication.ReplicationQueueId queueId) |
private String |
getFileName(String base,
int i) |
private org.apache.hadoop.hbase.ServerName |
getServerName(int i) |
static void |
setUp() |
void |
setUpBeforeTest() |
static void |
tearDown() |
void |
testClaimQueue() |
void |
testClaimQueueMultiThread() |
void |
testGetSetOffset() |
void |
testHfileRefsReplicationQueues() |
void |
testListRemovePeerAllQueues() |
void |
testPersistLogPositionAndSeqIdAtomically() |
void |
testRemoveAllLastPushedSeqIdsForPeer() |
void |
testRemoveLastSequenceIdsAndHFileRefsBefore() |
void |
testRemovePeerForHFileRefs() |
void |
testReplicator() |
public static final HBaseClassTestRule CLASS_RULE
private static final org.slf4j.Logger LOG
private static final HBaseTestingUtil UTIL
public TableNameTestRule tableNameRule
private org.apache.hadoop.hbase.replication.TableReplicationQueueStorage storage
public TestTableReplicationQueueStorage()
public static void tearDown() throws IOException
IOException
public void setUpBeforeTest() throws Exception
Exception
private org.apache.hadoop.hbase.ServerName getServerName(int i)
private String getFileName(String base, int i)
public void testReplicator() throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
public void testGetSetOffset()
private void assertQueueId(String peerId, org.apache.hadoop.hbase.ServerName serverName, org.apache.hadoop.hbase.replication.ReplicationQueueId queueId)
public void testPersistLogPositionAndSeqIdAtomically() throws Exception
Exception
private void assertGroupOffset(String wal, long offset, org.apache.hadoop.hbase.replication.ReplicationGroupOffset groupOffset)
public void testClaimQueue() throws Exception
Exception
public void testClaimQueueMultiThread() throws Exception
Exception
public void testListRemovePeerAllQueues() throws Exception
Exception
public void testRemoveAllLastPushedSeqIdsForPeer() throws Exception
Exception
public void testHfileRefsReplicationQueues() throws org.apache.hadoop.hbase.replication.ReplicationException, org.apache.zookeeper.KeeperException
org.apache.hadoop.hbase.replication.ReplicationException
org.apache.zookeeper.KeeperException
public void testRemovePeerForHFileRefs() throws org.apache.hadoop.hbase.replication.ReplicationException, org.apache.zookeeper.KeeperException
org.apache.hadoop.hbase.replication.ReplicationException
org.apache.zookeeper.KeeperException
private void addLastSequenceIdsAndHFileRefs(String peerId1, String peerId2) throws org.apache.hadoop.hbase.replication.ReplicationException
org.apache.hadoop.hbase.replication.ReplicationException
public void testRemoveLastSequenceIdsAndHFileRefsBefore() throws org.apache.hadoop.hbase.replication.ReplicationException, InterruptedException
org.apache.hadoop.hbase.replication.ReplicationException
InterruptedException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.