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

Class TestWALEntrySinkFilter

java.lang.Object

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

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.DevNullAsyncConnection	A DevNull AsyncConnection whose only purpose is checking what edits made it through.
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
static final HBaseClassTestRule	CLASS_RULE
(package private) static final AtomicInteger	FILTERED
private static final org.slf4j.Logger	LOG
org.junit.rules.TestName	name
private static org.apache.hadoop.hbase.Stoppable	STOPPABLE	Implemetentation of Stoppable to pass into ReplicationSink.
(package private) static final AtomicInteger	UNFILTERED

Constructor Summary

Constructors

Constructor	Description
TestWALEntrySinkFilter()

Method Summary

Modifier and Type	Method	Description
void	testWALEntryFilter()	Test filter.

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

LOG

private static final org.slf4j.Logger LOG

name

public org.junit.rules.TestName name

BOUNDARY

static final int BOUNDARY

See Also:

• Constant Field Values

UNFILTERED

static final AtomicInteger UNFILTERED

FILTERED

static final AtomicInteger FILTERED

STOPPABLE

private static org.apache.hadoop.hbase.Stoppable STOPPABLE

Implemetentation of Stoppable to pass into ReplicationSink.

Constructor Details

TestWALEntrySinkFilter

public TestWALEntrySinkFilter()

Method Details

testWALEntryFilter

public void testWALEntryFilter()
                        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