oracle.pg.hbase

Class OracleValueFilter

java.lang.Object

org.apache.hadoop.hbase.filter.Filter

org.apache.hadoop.hbase.filter.FilterBase

org.apache.hadoop.hbase.filter.CompareFilter

oracle.pg.hbase.OracleValueFilter

public class OracleValueFilter
extends org.apache.hadoop.hbase.filter.CompareFilter

This class contains a value filter to restrict the cells retrieved based on a specific value comparator. This is modified with respect to HBase Value Filter to filter rows with value length greater than 0.

Nested Class Summary

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

org.apache.hadoop.hbase.filter.CompareFilter.CompareOp

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

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

Constructor Summary

Constructors

Constructor and Description
OracleValueFilter(org.apache.hadoop.hbase.filter.CompareFilter.CompareOp op, org.apache.hadoop.hbase.filter.ByteArrayComparable valueComparator) Creates a new instance of an OracleValueFilter used in getVertices/getEdges operations.

Method Summary

Methods

Modifier and Type	Method and Description
static org.apache.hadoop.hbase.filter.Filter	createFilterFromArguments(ArrayList<byte[]> filterArguments) Given the filter's arguments construct the filter.
org.apache.hadoop.hbase.filter.Filter.ReturnCode	filterKeyValue(org.apache.hadoop.hbase.Cell c) Filter the row if the K/V pair is not found in the row data.
boolean	filterRow() Get filter status for this specified row
boolean	hasFilterRow() Check if this filter allows to filter a row
static OracleValueFilter	parseFrom(byte[] pbBytes)
void	reset() Reset filter row to true.
byte[]	toByteArray() Write filter's info as a byte array

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

extractArguments, getComparator, getOperator, toString

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

filterAllRemaining, filterRow, filterRowCells, filterRowKey, getNextCellHint, getNextKeyHint, isFamilyEssential, transform, transformCell

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

isReversed, setReversed

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

OracleValueFilter

public OracleValueFilter(org.apache.hadoop.hbase.filter.CompareFilter.CompareOp op,
                 org.apache.hadoop.hbase.filter.ByteArrayComparable valueComparator)

Creates a new instance of an OracleValueFilter used in getVertices/getEdges operations.

Parameters:

op - the compare op for row matching

valueComparator - the comparator for row matching

Method Detail

createFilterFromArguments

public static org.apache.hadoop.hbase.filter.Filter createFilterFromArguments(ArrayList<byte[]> filterArguments)

Given the filter's arguments construct the filter.

Parameters:

filterArguments - the filter's arguments.

Returns:

a Filter object.

filterKeyValue

public org.apache.hadoop.hbase.filter.Filter.ReturnCode filterKeyValue(org.apache.hadoop.hbase.Cell c)

Filter the row if the K/V pair is not found in the row data.

Overrides:

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

Parameters:

c - the cell in question

filterRow

public boolean filterRow()

Get filter status for this specified row

Overrides:

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

hasFilterRow

public boolean hasFilterRow()

Check if this filter allows to filter a row

Overrides:

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

parseFrom

public static OracleValueFilter parseFrom(byte[] pbBytes)
                                   throws org.apache.hadoop.hbase.exceptions.DeserializationException

Throws:

org.apache.hadoop.hbase.exceptions.DeserializationException

reset

public void reset()

Reset filter row to true.

Overrides:

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

toByteArray

public byte[] toByteArray()
                   throws IOException

Write filter's info as a byte array

Overrides:

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

Returns:

the byte array representation of the filter's info

Throws:

IOException