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

Class TestRegionReplicationSink

java.lang.Object

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

@Tag("org.apache.hadoop.hbase.testclassification.RegionServerTests") @Tag("org.apache.hadoop.hbase.testclassification.MediumTests")
public class TestRegionReplicationSink
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
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 TableNameTestExtension	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	testAllReplicaFailed()	This test is for HBASE-29230, when all replicas are failed, resource should be released completely.
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

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

@RegisterExtension
public final TableNameTestExtension name

Constructor Details

TestRegionReplicationSink

public TestRegionReplicationSink()

Method Details

setUp

@BeforeEach
public void setUp()

tearDown

@AfterEach
public void tearDown()
              throws InterruptedException

Throws:

InterruptedException

testNormal

@Test
public void testNormal()

testDropEdits

@Test
public void testDropEdits()

testNotAddToFailedReplicas

@Test
public void testNotAddToFailedReplicas()

testAddToFailedReplica

@Test
public void testAddToFailedReplica()

testAllReplicaFailed

@Test
public void testAllReplicaFailed()

This test is for HBASE-29230, when all replicas are failed, resource should be released completely.

testSizeCapacity

@Test
public void testSizeCapacity()

testCountCapacity

@Test
public void testCountCapacity()