co.cask.cdap.data2.increment.hbase98

Class IncrementTxFilter

java.lang.Object

org.apache.hadoop.hbase.filter.Filter

org.apache.hadoop.hbase.filter.FilterBase

org.apache.tephra.hbase.coprocessor.TransactionVisibilityFilter

co.cask.cdap.data2.increment.hbase98.IncrementTxFilter

public class IncrementTxFilter
extends org.apache.tephra.hbase.coprocessor.TransactionVisibilityFilter

TransactionVisibilityFilter's default behavior is to give only latest valid version for the transactional cell to its sub-filters. However the IncrementFilter need to see all previous valid versions for readless increments, since increments are stored as just the different versions of the same cell. This Filter extends the TransactionVisibilityFilter and overrides the TransactionVisibilityFilter.determineReturnCode(org.apache.hadoop.hbase.filter.Filter.ReturnCode, org.apache.hadoop.hbase.filter.Filter.ReturnCode) method to achieve this.

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
IncrementTxFilter(org.apache.tephra.Transaction tx, Map<byte[],Long> ttlByFamily, boolean allowEmptyValues, org.apache.hadoop.hbase.regionserver.ScanType scanType, org.apache.hadoop.hbase.filter.Filter cellFilter) Creates a new instance of the Filter.

Method Summary

Methods

Modifier and Type	Method and Description
protected org.apache.hadoop.hbase.filter.Filter.ReturnCode	determineReturnCode(org.apache.hadoop.hbase.filter.Filter.ReturnCode txFilterCode, org.apache.hadoop.hbase.filter.Filter.ReturnCode subFilterCode)

Methods inherited from class org.apache.tephra.hbase.coprocessor.TransactionVisibilityFilter

filterAllRemaining, filterKeyValue, filterRow, filterRowCells, filterRowKey, getNextCellHint, getNextKeyHint, hasFilterRow, isFamilyEssential, reset, toByteArray, transformCell

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

createFilterFromArguments, filterRow, toString, transform

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

IncrementTxFilter

public IncrementTxFilter(org.apache.tephra.Transaction tx,
                 Map<byte[],Long> ttlByFamily,
                 boolean allowEmptyValues,
                 org.apache.hadoop.hbase.regionserver.ScanType scanType,
                 org.apache.hadoop.hbase.filter.Filter cellFilter)

Creates a new instance of the Filter.

Parameters:

tx - the current transaction to apply. Only data visible to this transaction will be returned

ttlByFamily - map of time-to-live (TTL) (in milliseconds) by column family name

allowEmptyValues - if true cells with empty byte[] values will be returned, if false these will be interpreted as "delete" markers and the column will be filtered out

scanType - the type of scan operation being performed

cellFilter - if non-null, this filter will be applied to all cells visible to the current transaction, by calling Filter.filterKeyValue(org.apache.hadoop.hbase.Cell). If null, then Filter.ReturnCode#INCLUDE_AND_NEXT_COL will be returned instead.

Method Detail

determineReturnCode

protected org.apache.hadoop.hbase.filter.Filter.ReturnCode determineReturnCode(org.apache.hadoop.hbase.filter.Filter.ReturnCode txFilterCode,
                                                                   org.apache.hadoop.hbase.filter.Filter.ReturnCode subFilterCode)

Overrides:

determineReturnCode in class org.apache.tephra.hbase.coprocessor.TransactionVisibilityFilter