public class TestWALEntrySinkFilter extends Object
Modifier and Type | Class and 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.
|
Modifier and Type | Field and Description |
---|---|
(package private) static int |
BOUNDARY |
static HBaseClassTestRule |
CLASS_RULE |
(package private) static AtomicInteger |
FILTERED |
org.junit.rules.TestName |
name |
(package private) static AtomicInteger |
UNFILTERED |
Constructor and Description |
---|
TestWALEntrySinkFilter() |
Modifier and Type | Method and Description |
---|---|
void |
testWALEntryFilter()
Test filter.
|
public static final HBaseClassTestRule CLASS_RULE
public org.junit.rules.TestName name
static final int BOUNDARY
static final AtomicInteger UNFILTERED
static final AtomicInteger FILTERED
public TestWALEntrySinkFilter()
public void testWALEntryFilter() throws IOException
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.