Package org.apache.hadoop.hbase.replication.regionserver

Class TestReplicationSourceShipperRestart

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.TestReplicationSourceShipperRestart

@Tag("org.apache.hadoop.hbase.testclassification.ReplicationTests") @Tag("org.apache.hadoop.hbase.testclassification.SmallTests")
public class TestReplicationSourceShipperRestart
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
private org.apache.hadoop.hbase.replication.ReplicationEndpoint	endpoint
private org.apache.hadoop.hbase.replication.regionserver.MetricsSource	metrics
private static final org.apache.hadoop.fs.Path	PATH
private org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader	reader
private org.apache.hadoop.hbase.replication.regionserver.ReplicationSource	source

Constructor Summary

Constructors

Constructor	Description
TestReplicationSourceShipperRestart()

Method Summary

Modifier and Type	Method	Description
private org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch	batch(long size)
private org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch	emptyBatch()
private org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceShipper	lightShipper(org.apache.hadoop.conf.Configuration conf)	Light shipper → skips persist logic
private org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceShipper	realShipper(org.apache.hadoop.conf.Configuration conf)	Real shipper → executes persist logic
void	setup()
void	testAbortAndRestart()
void	testBeforePersistCalledBeforeUpdate()
void	testBeforePersistHookCalled()
void	testDefaultImmediatePersist()
void	testEmptyBatchTriggersPersist()
void	testPersistFailureThrows()
void	testPersistFailureTriggersRestart()
void	testRunNormalFlow()
void	testSizeThreshold()
void	testTimeThreshold()

Methods inherited from class java.lang.Object

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

Field Details

source

private org.apache.hadoop.hbase.replication.regionserver.ReplicationSource source

reader

private org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceWALReader reader

metrics

private org.apache.hadoop.hbase.replication.regionserver.MetricsSource metrics

endpoint

private org.apache.hadoop.hbase.replication.ReplicationEndpoint endpoint

PATH

private static final org.apache.hadoop.fs.Path PATH

Constructor Details

TestReplicationSourceShipperRestart

public TestReplicationSourceShipperRestart()

Method Details

setup

@BeforeEach
public void setup()

emptyBatch

private org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch emptyBatch()

batch

private org.apache.hadoop.hbase.replication.regionserver.WALEntryBatch batch(long size)

lightShipper

private org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceShipper lightShipper(org.apache.hadoop.conf.Configuration conf)

Light shipper → skips persist logic

realShipper

private org.apache.hadoop.hbase.replication.regionserver.ReplicationSourceShipper realShipper(org.apache.hadoop.conf.Configuration conf)

Real shipper → executes persist logic

testAbortAndRestart

@Test
public void testAbortAndRestart()

testEmptyBatchTriggersPersist

@Test
public void testEmptyBatchTriggersPersist()
                                   throws Exception

Throws:

Exception

testDefaultImmediatePersist

@Test
public void testDefaultImmediatePersist()
                                 throws Exception

Throws:

Exception

testSizeThreshold

@Test
public void testSizeThreshold()
                       throws Exception

Throws:

Exception

testTimeThreshold

@Test
public void testTimeThreshold()
                       throws Exception

Throws:

Exception

testBeforePersistHookCalled

@Test
public void testBeforePersistHookCalled()
                                 throws Exception

Throws:

Exception

testBeforePersistCalledBeforeUpdate

@Test
public void testBeforePersistCalledBeforeUpdate()
                                         throws Exception

Throws:

Exception

testPersistFailureThrows

@Test
public void testPersistFailureThrows()
                              throws Exception

Throws:

Exception

testPersistFailureTriggersRestart

@Test
@Timeout(30L)
public void testPersistFailureTriggersRestart()
                                       throws Exception

Throws:

Exception

testRunNormalFlow

@Test
@Timeout(30L)
public void testRunNormalFlow()
                       throws Exception

Throws:

Exception