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.
  • Constructor Details

  • Method Details

    • init

      public void init(org.apache.hadoop.hbase.client.AsyncConnection conn)
      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