com.bigdata.sparse

Class AtomicRowFilter

java.lang.Object

cutthecrap.utils.striterators.FilterBase

com.bigdata.btree.filter.TupleTransformer<TPS.TPV,TPS>

com.bigdata.sparse.AtomicRowFilter

All Implemented Interfaces:

ITupleFilter<TPS>, IRowStoreConstants, IFilter, IPropertySet, Serializable, Cloneable

public class AtomicRowFilter
extends TupleTransformer<TPS.TPV,TPS>
implements IRowStoreConstants

Transforms an ITupleIterator reading directly on an IIndex backing a SparseRowStore into an ITupleIterator visiting logical ITPS rows.

Version:

$Id$

Author:

Bryan Thompson

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected static org.apache.log4j.Logger	log

Fields inherited from class com.bigdata.btree.filter.TupleTransformer

tupleSer

Fields inherited from interface com.bigdata.sparse.IRowStoreConstants

AUTO_TIMESTAMP, AUTO_TIMESTAMP_UNIQUE, CURRENT_ROW, MAX_TIMESTAMP, MIN_TIMESTAMP

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	AtomicRowFilter(Schema schema, long fromTime, long toTime, INameFilter nameFilter)

Method Summary

Methods

Modifier and Type	Method and Description
protected ITupleIterator<TPS>	newTransformer(LookaheadTupleFilter.ILookaheadTupleIterator<TPS.TPV> src, Object context) Method responsible for creating a new instance of the iterator that reads from the lookahead source whose tuples are of the source type and visits the transformed tuples.

Methods inherited from class com.bigdata.btree.filter.TupleTransformer

filterOnce

Methods inherited from class cutthecrap.utils.striterators.FilterBase

addFilter, filter, getProperty, getRequiredProperty, setProperty, toString

Methods inherited from class java.lang.Object

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

Methods inherited from interface cutthecrap.utils.striterators.IFilter

filter

Methods inherited from interface cutthecrap.utils.striterators.IPropertySet

getProperty

Field Detail

log

protected static final transient org.apache.log4j.Logger log

Constructor Detail

AtomicRowFilter

protected AtomicRowFilter(Schema schema,
               long fromTime,
               long toTime,
               INameFilter nameFilter)

Parameters:

schema - The schema governing the row.

fromTime - The first timestamp for which timestamped property values will be accepted.

toTime - The first timestamp for which timestamped property values will NOT be accepted -or- IRowStoreConstants.CURRENT_ROW to accept only the most current binding whose timestamp is GTE fromTime.

nameFilter - An optional filter used to select the values for property names accepted by that filter.

Method Detail

newTransformer

protected ITupleIterator<TPS> newTransformer(LookaheadTupleFilter.ILookaheadTupleIterator<TPS.TPV> src,
                                 Object context)

Description copied from class: TupleTransformer

Method responsible for creating a new instance of the iterator that reads from the lookahead source whose tuples are of the source type and visits the transformed tuples.

Specified by:

newTransformer in class TupleTransformer<TPS.TPV,TPS>