Package org.apache.cassandra.db.transform

Class FilteredPartitions

java.lang.Object

org.apache.cassandra.db.transform.BasePartitions<RowIterator,BasePartitionIterator<?>>

org.apache.cassandra.db.transform.FilteredPartitions

All Implemented Interfaces:

AutoCloseable, Iterator<RowIterator>, BasePartitionIterator<RowIterator>, PartitionIterator, CloseableIterator<RowIterator>

public final class FilteredPartitions
extends BasePartitions<RowIterator,BasePartitionIterator<?>>
implements PartitionIterator

Field Summary

Fields

Modifier and Type	Field	Description
static final org.apache.cassandra.db.transform.Stack.MoreContentsHolder[]	EMPTY_MORE_CONTENTS_HOLDERS
static final Transformation[]	EMPTY_TRANSFORMATIONS

Method Summary

Modifier and Type	Method	Description
final void	close()
static FilteredPartitions	filter(UnfilteredPartitionIterator iterator, long nowInSecs)	Filter any RangeTombstoneMarker from the iterator's iterators, transforming it into a PartitionIterator.
static FilteredPartitions	filter(UnfilteredPartitionIterator iterator, Filter filter)
protected final boolean	hasMoreContents()
final RowIterator	next()

Methods inherited from class org.apache.cassandra.db.transform.BasePartitions

applyOne, hasNext, runOnClose

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cassandra.db.partitions.BasePartitionIterator

close

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext, next, remove

Field Details

EMPTY_TRANSFORMATIONS

public static final Transformation[] EMPTY_TRANSFORMATIONS

EMPTY_MORE_CONTENTS_HOLDERS

public static final org.apache.cassandra.db.transform.Stack.MoreContentsHolder[] EMPTY_MORE_CONTENTS_HOLDERS

Method Details

filter

public static FilteredPartitions filter(UnfilteredPartitionIterator iterator,
 long nowInSecs)

Filter any RangeTombstoneMarker from the iterator's iterators, transforming it into a PartitionIterator.

filter

public static FilteredPartitions filter(UnfilteredPartitionIterator iterator,
 Filter filter)

close

public final void close()

Specified by:

close in interface AutoCloseable

next

public final RowIterator next()

Specified by:

next in interface Iterator<V>

hasMoreContents

protected final boolean hasMoreContents()