Package org.apache.hadoop.hbase.regionserver.regionreplication

Class TestRegionReplicationSink

java.lang.Object

org.apache.hadoop.hbase.regionserver.regionreplication.TestRegionReplicationSink

public class TestRegionReplicationSink
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static final HBaseClassTestRule	CLASS_RULE
private org.apache.hadoop.conf.Configuration	conf
private org.apache.hadoop.hbase.client.AsyncClusterConnection	conn
private Runnable	flushRequester
private org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationBufferManager	manager
final TableNameTestRule	name
private org.apache.hadoop.hbase.client.RegionInfo	primary
private org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSink	sink
private org.apache.hadoop.hbase.client.TableDescriptor	td

Constructor Summary

Constructors

Constructor	Description
TestRegionReplicationSink()

Method Summary

Modifier and Type	Method	Description
void	setUp()
void	tearDown()
void	testAddToFailedReplica()
void	testCountCapacity()
void	testDropEdits()
void	testNormal()
void	testNotAddToFailedReplicas()
void	testSizeCapacity()

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

conf

private org.apache.hadoop.conf.Configuration conf

td

private org.apache.hadoop.hbase.client.TableDescriptor td

primary

private org.apache.hadoop.hbase.client.RegionInfo primary

flushRequester

private Runnable flushRequester

conn

private org.apache.hadoop.hbase.client.AsyncClusterConnection conn

manager

private org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationBufferManager manager

sink

private org.apache.hadoop.hbase.regionserver.regionreplication.RegionReplicationSink sink

name

public final TableNameTestRule name

Constructor Details

TestRegionReplicationSink

public TestRegionReplicationSink()

Method Details

setUp

public void setUp()

tearDown

public void tearDown()
              throws InterruptedException

Throws:

InterruptedException

testNormal

public void testNormal()

testDropEdits

public void testDropEdits()

testNotAddToFailedReplicas

public void testNotAddToFailedReplicas()

testAddToFailedReplica

public void testAddToFailedReplica()

testSizeCapacity

public void testSizeCapacity()

testCountCapacity

public void testCountCapacity()