public class AtomicRowFilter extends TupleTransformer<TPS.TPV,TPS> implements IRowStoreConstants
ITupleIteratorreading directly on an
TupleTransformer., You could replace the
AtomicRowReadwith this iterator by setting the capacity to ONE (1). However, that will do more work when we are only trying to read a single row on a local index since we will have to serialize and then de-serialize the
TPSfor that logical row. (For a remote read the effort should be the same).
|Modifier and Type||Field and Description|
|Modifier||Constructor and Description|
|Modifier and Type||Method and Description|
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.
addFilter, filter, getProperty, getRequiredProperty, setProperty, toString
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
protected AtomicRowFilter(Schema schema, long fromTime, long toTime, INameFilter nameFilter)
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_ROWto 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.
protected ITupleIterator<TPS> newTransformer(LookaheadTupleFilter.ILookaheadTupleIterator<TPS.TPV> src, java.lang.Object context)
Copyright © 2006-2014 SYSTAP, LLC. All Rights Reserved.