co.cask.cdap.data2.increment.hbase98

Class IncrementFilter

java.lang.Object

org.apache.hadoop.hbase.filter.Filter

org.apache.hadoop.hbase.filter.FilterBase

co.cask.cdap.data2.increment.hbase98.IncrementFilter

public class IncrementFilter
extends org.apache.hadoop.hbase.filter.FilterBase

Simple filter for increment columns that includes all cell values in a column with a "delta" prefix up to and including the first cell it finds that is not an increment. This allows the IncrementHandler coprocessor to return the correct value for an increment column by summing the last total sum plus all newer delta values.

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.hbase.filter.Filter

org.apache.hadoop.hbase.filter.Filter.ReturnCode

Field Summary

Fields inherited from class org.apache.hadoop.hbase.filter.Filter

reversed

Constructor Summary

Constructors

Constructor and Description
IncrementFilter()

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.hadoop.hbase.filter.Filter.ReturnCode	filterKeyValue(org.apache.hadoop.hbase.Cell cell)

Methods inherited from class org.apache.hadoop.hbase.filter.FilterBase

createFilterFromArguments, filterAllRemaining, filterRow, filterRow, filterRowCells, filterRowKey, getNextCellHint, getNextKeyHint, hasFilterRow, isFamilyEssential, reset, toByteArray, toString, transform, transformCell

Methods inherited from class org.apache.hadoop.hbase.filter.Filter

isReversed, parseFrom, setReversed

Methods inherited from class java.lang.Object

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

Constructor Detail

IncrementFilter

public IncrementFilter()

Method Detail

filterKeyValue

public org.apache.hadoop.hbase.filter.Filter.ReturnCode filterKeyValue(org.apache.hadoop.hbase.Cell cell)
                                                                throws IOException

Overrides:

filterKeyValue in class org.apache.hadoop.hbase.filter.FilterBase

Throws:

IOException