org.apache.hadoop.hbase.replication.regionserver

Class TestWALEntrySinkFilter.IfTimeIsGreaterThanBOUNDARYWALEntrySinkFilterImpl

java.lang.Object

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

All Implemented Interfaces:

org.apache.hadoop.hbase.replication.regionserver.WALEntrySinkFilter

Enclosing class:

TestWALEntrySinkFilter

public static class TestWALEntrySinkFilter.IfTimeIsGreaterThanBOUNDARYWALEntrySinkFilterImpl
extends Object
implements org.apache.hadoop.hbase.replication.regionserver.WALEntrySinkFilter

Simple filter that will filter out any entry wholse writeTime is <= 5.

Field Summary

Fields inherited from interface org.apache.hadoop.hbase.replication.regionserver.WALEntrySinkFilter

WAL_ENTRY_FILTER_KEY

Constructor Summary

Constructors

Constructor and Description
IfTimeIsGreaterThanBOUNDARYWALEntrySinkFilterImpl()

Method Summary

Modifier and Type	Method and Description
boolean	filter(org.apache.hadoop.hbase.TableName table, long writeTime)
void	init(org.apache.hadoop.hbase.client.Connection connection)

Methods inherited from class java.lang.Object

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

Constructor Detail

IfTimeIsGreaterThanBOUNDARYWALEntrySinkFilterImpl

public IfTimeIsGreaterThanBOUNDARYWALEntrySinkFilterImpl()

Method Detail

init

public void init(org.apache.hadoop.hbase.client.Connection connection)

Specified by:

init in interface org.apache.hadoop.hbase.replication.regionserver.WALEntrySinkFilter

filter

public boolean filter(org.apache.hadoop.hbase.TableName table,
                      long writeTime)

Specified by:

filter in interface org.apache.hadoop.hbase.replication.regionserver.WALEntrySinkFilter