public class CellSkipFilter
extends org.apache.hadoop.hbase.filter.FilterBase
Filter
that encapsulates another Filter
. It remembers the last KeyValue
for which the underlying filter returned the ReturnCode#NEXT_COL
or ReturnCode#INCLUDE_AND_NEXT_COL
,
so that when filterKeyValue(org.apache.hadoop.hbase.Cell)
is called again for the same KeyValue
with different
version, it returns ReturnCode#NEXT_COL
directly without consulting the underlying Filter
.
Please see TEPHRA-169 for more details.Constructor and Description |
---|
CellSkipFilter(org.apache.hadoop.hbase.filter.Filter filter) |
Modifier and Type | Method and Description |
---|---|
boolean |
filterAllRemaining() |
org.apache.hadoop.hbase.filter.Filter.ReturnCode |
filterKeyValue(org.apache.hadoop.hbase.Cell cell) |
boolean |
filterRow() |
void |
filterRowCells(List<org.apache.hadoop.hbase.Cell> kvs) |
boolean |
filterRowKey(byte[] buffer,
int offset,
int length) |
org.apache.hadoop.hbase.Cell |
getNextCellHint(org.apache.hadoop.hbase.Cell currentKV) |
org.apache.hadoop.hbase.KeyValue |
getNextKeyHint(org.apache.hadoop.hbase.KeyValue currentKV) |
boolean |
hasFilterRow() |
boolean |
isFamilyEssential(byte[] name) |
void |
reset() |
byte[] |
toByteArray() |
org.apache.hadoop.hbase.Cell |
transformCell(org.apache.hadoop.hbase.Cell cell) |
createFilterFromArguments, filterRowKey, toString
public CellSkipFilter(org.apache.hadoop.hbase.filter.Filter filter)
public org.apache.hadoop.hbase.filter.Filter.ReturnCode filterKeyValue(org.apache.hadoop.hbase.Cell cell) throws IOException
filterKeyValue
in class org.apache.hadoop.hbase.filter.Filter
IOException
public boolean filterRow() throws IOException
filterRow
in class org.apache.hadoop.hbase.filter.FilterBase
IOException
public org.apache.hadoop.hbase.Cell transformCell(org.apache.hadoop.hbase.Cell cell) throws IOException
transformCell
in class org.apache.hadoop.hbase.filter.FilterBase
IOException
public void reset() throws IOException
reset
in class org.apache.hadoop.hbase.filter.FilterBase
IOException
public boolean filterRowKey(byte[] buffer, int offset, int length) throws IOException
filterRowKey
in class org.apache.hadoop.hbase.filter.FilterBase
IOException
public boolean filterAllRemaining() throws IOException
filterAllRemaining
in class org.apache.hadoop.hbase.filter.FilterBase
IOException
public void filterRowCells(List<org.apache.hadoop.hbase.Cell> kvs) throws IOException
filterRowCells
in class org.apache.hadoop.hbase.filter.FilterBase
IOException
public boolean hasFilterRow()
hasFilterRow
in class org.apache.hadoop.hbase.filter.FilterBase
public org.apache.hadoop.hbase.KeyValue getNextKeyHint(org.apache.hadoop.hbase.KeyValue currentKV) throws IOException
IOException
public org.apache.hadoop.hbase.Cell getNextCellHint(org.apache.hadoop.hbase.Cell currentKV) throws IOException
getNextCellHint
in class org.apache.hadoop.hbase.filter.FilterBase
IOException
public boolean isFamilyEssential(byte[] name) throws IOException
isFamilyEssential
in class org.apache.hadoop.hbase.filter.FilterBase
IOException
public byte[] toByteArray() throws IOException
toByteArray
in class org.apache.hadoop.hbase.filter.FilterBase
IOException
Copyright © 2018 The Apache Software Foundation. All rights reserved.