org.apache.hadoop.hive.accumulo.predicate

Class PrimitiveComparisonFilter

java.lang.Object

org.apache.accumulo.core.iterators.user.WholeRowIterator

org.apache.hadoop.hive.accumulo.predicate.PrimitiveComparisonFilter

All Implemented Interfaces:

org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>

public class PrimitiveComparisonFilter
extends org.apache.accumulo.core.iterators.user.WholeRowIterator

Operates over a single qualifier. Delegates to PrimitiveCompare and CompareOpt instances for value acceptance. The PrimitiveCompare strategy assumes a consistent value type for the same column family and qualifier.

Field Summary

Fields

Modifier and Type	Field and Description
static String	COLUMN
static String	COMPARE_OPT_CLASS
static String	CONST_VAL
static String	FILTER_PREFIX
static String	P_COMPARE_CLASS

Constructor Summary

Constructors

Constructor and Description
PrimitiveComparisonFilter()

Method Summary

Methods

Modifier and Type	Method and Description
protected boolean	filter(org.apache.hadoop.io.Text currentRow, List<org.apache.accumulo.core.data.Key> keys, List<org.apache.accumulo.core.data.Value> values)
protected byte[]	getConstant(Map<String,String> options)
void	init(org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> source, Map<String,String> options, org.apache.accumulo.core.iterators.IteratorEnvironment env)

Methods inherited from class org.apache.accumulo.core.iterators.user.WholeRowIterator

decodeRow, deepCopy, encodeRow, getTopKey, getTopValue, hasTop, next, seek

Methods inherited from class java.lang.Object

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

Field Detail

FILTER_PREFIX

public static final String FILTER_PREFIX

See Also:

Constant Field Values

P_COMPARE_CLASS

public static final String P_COMPARE_CLASS

See Also:

Constant Field Values

COMPARE_OPT_CLASS

public static final String COMPARE_OPT_CLASS

See Also:

Constant Field Values

CONST_VAL

public static final String CONST_VAL

See Also:

Constant Field Values

COLUMN

public static final String COLUMN

See Also:

Constant Field Values

Constructor Detail

PrimitiveComparisonFilter

public PrimitiveComparisonFilter()

Method Detail

filter

protected boolean filter(org.apache.hadoop.io.Text currentRow,
             List<org.apache.accumulo.core.data.Key> keys,
             List<org.apache.accumulo.core.data.Value> values)

Overrides:

filter in class org.apache.accumulo.core.iterators.user.WholeRowIterator

init

public void init(org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> source,
        Map<String,String> options,
        org.apache.accumulo.core.iterators.IteratorEnvironment env)
          throws IOException

Specified by:

init in interface org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>

Overrides:

init in class org.apache.accumulo.core.iterators.user.WholeRowIterator

Throws:

IOException

getConstant

protected byte[] getConstant(Map<String,String> options)