Package org.teiid.translator.accumulo

Class BaseFilterIterator

java.lang.Object

org.apache.accumulo.core.iterators.WrappingIterator

org.apache.accumulo.core.iterators.user.RowFilter

org.teiid.translator.accumulo.BaseFilterIterator

All Implemented Interfaces:

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

public abstract class BaseFilterIterator
extends org.apache.accumulo.core.iterators.user.RowFilter

Base class for Filters

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.accumulo.core.iterators.conf.ColumnSet	columnFilter
static String	NEGATE
protected AccumuloMetadataProcessor.ValueIn	valueIn

Constructor Summary

Constructors

Constructor	Description
BaseFilterIterator()

Method Summary

Modifier and Type	Method	Description
boolean	accept(byte[] value)
boolean	acceptRow(org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> rowItem)
org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value>	deepCopy(org.apache.accumulo.core.iterators.IteratorEnvironment env)
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.RowFilter

hasTop, next, seek

Methods inherited from class org.apache.accumulo.core.iterators.WrappingIterator

getSource, getTopKey, getTopValue, setSource

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.accumulo.core.iterators.YieldingKeyValueIterator

enableYielding

Field Detail

NEGATE

public static final String NEGATE

See Also:

Constant Field Values

valueIn

protected AccumuloMetadataProcessor.ValueIn valueIn

columnFilter

protected org.apache.accumulo.core.iterators.conf.ColumnSet columnFilter

Constructor Detail

BaseFilterIterator

public BaseFilterIterator()

Method Detail

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.RowFilter

Throws:

IOException

deepCopy

public org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> deepCopy(org.apache.accumulo.core.iterators.IteratorEnvironment env)

Specified by:

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

Overrides:

deepCopy in class org.apache.accumulo.core.iterators.user.RowFilter

acceptRow

public boolean acceptRow(org.apache.accumulo.core.iterators.SortedKeyValueIterator<org.apache.accumulo.core.data.Key,org.apache.accumulo.core.data.Value> rowItem)
                  throws IOException

Specified by:

acceptRow in class org.apache.accumulo.core.iterators.user.RowFilter

Throws:

IOException

accept

public boolean accept(byte[] value)