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 and Description
static class	TestWALEntrySinkFilter.DevNullConnection A DevNull Connection whose only purpose is checking what edits made it through.
static class	TestWALEntrySinkFilter.IfTimeIsGreaterThanBOUNDARYWALEntrySinkFilterImpl Simple filter that will filter out any entry wholse writeTime is <= 5.

Field Summary

Fields

Modifier and Type	Field and Description
(package private) static int	BOUNDARY
static HBaseClassTestRule	CLASS_RULE
(package private) static AtomicInteger	FILTERED
private static 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 AtomicInteger	UNFILTERED

Constructor Summary

Constructors

Constructor and Description
TestWALEntrySinkFilter()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

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 Detail

TestWALEntrySinkFilter

public TestWALEntrySinkFilter()

Method Detail

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