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

Class TestWALEntrySinkFilter

java.lang.Object

org.apache.hadoop.hbase.replication.regionserver.TestWALEntrySinkFilter

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

Simple test of sink-side wal entry filter facility.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	TestWALEntrySinkFilter.DevNullAsyncClusterConnection
static class	TestWALEntrySinkFilter.DevNullConnectionRegistry
static class	TestWALEntrySinkFilter.IfTimeIsGreaterThanBOUNDARYWALEntrySinkFilterImpl	Simple filter that will filter out any entry wholse writeTime is <= 5.

Field Summary

Fields

Modifier and Type	Field	Description
(package private) static final int	BOUNDARY
(package private) static final AtomicInteger	FILTERED
(package private) static final AtomicInteger	UNFILTERED

Constructor Summary

Constructors

Constructor	Description
TestWALEntrySinkFilter()

Method Summary

Modifier and Type	Method	Description
void	testWALEntryFilter(org.junit.jupiter.api.TestInfo testInfo)	Test filter.

Methods inherited from class java.lang.Object

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

Field Details

BOUNDARY

static final int BOUNDARY

See Also:

• Constant Field Values

UNFILTERED

static final AtomicInteger UNFILTERED

FILTERED

static final AtomicInteger FILTERED

Constructor Details

TestWALEntrySinkFilter

public TestWALEntrySinkFilter()

Method Details

testWALEntryFilter

@Test
public void testWALEntryFilter(org.junit.jupiter.api.TestInfo testInfo)
                        throws IOException

Test filter. Filter will filter out any write time that is <= 5 (BOUNDARY). We count how many items we filter out and we count how many cells make it through for distribution way down below in the Table#batch implementation. Puts in place a custom DevNullConnection so we can insert our counting Table.

Throws:

IOException