Package org.apache.cassandra.db.rows
Class AbstractUnfilteredRowIterator
- java.lang.Object
-
- org.apache.cassandra.utils.AbstractIterator<Unfiltered>
-
- org.apache.cassandra.db.rows.AbstractUnfilteredRowIterator
-
- All Implemented Interfaces:
com.google.common.collect.PeekingIterator<Unfiltered>
,java.lang.AutoCloseable
,java.util.Iterator<Unfiltered>
,BaseRowIterator<Unfiltered>
,UnfilteredRowIterator
,CloseableIterator<Unfiltered>
- Direct Known Subclasses:
RowAndDeletionMergeIterator
public abstract class AbstractUnfilteredRowIterator extends AbstractIterator<Unfiltered> implements UnfilteredRowIterator
-
-
Field Summary
Fields Modifier and Type Field Description protected RegularAndStaticColumns
columns
protected boolean
isReverseOrder
protected TableMetadata
metadata
protected DecoratedKey
partitionKey
protected DeletionTime
partitionLevelDeletion
protected Row
staticRow
protected EncodingStats
stats
-
Constructor Summary
Constructors Modifier Constructor Description protected
AbstractUnfilteredRowIterator(TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, RegularAndStaticColumns columns, Row staticRow, boolean isReverseOrder, EncodingStats stats)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
RegularAndStaticColumns
columns()
A subset of the columns for the (static and regular) rows returned by this iterator.boolean
isReverseOrder()
Whether or not the rows returned by this iterator are in reversed clustering order.TableMetadata
metadata()
The metadata for the table this iterator on.DecoratedKey
partitionKey()
The partition key of the partition this in an iterator over.DeletionTime
partitionLevelDeletion()
The partition level deletion for the partition this iterate over.Row
staticRow()
The static part corresponding to this partition (this can be an empty row but cannot benull
).EncodingStats
stats()
Return "statistics" about what is returned by this iterator.-
Methods inherited from class org.apache.cassandra.utils.AbstractIterator
computeNext, endOfData, hasNext, next, peek, remove
-
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.rows.UnfilteredRowIterator
isEmpty
-
-
-
-
Field Detail
-
metadata
protected final TableMetadata metadata
-
partitionKey
protected final DecoratedKey partitionKey
-
partitionLevelDeletion
protected final DeletionTime partitionLevelDeletion
-
columns
protected final RegularAndStaticColumns columns
-
staticRow
protected final Row staticRow
-
isReverseOrder
protected final boolean isReverseOrder
-
stats
protected final EncodingStats stats
-
-
Constructor Detail
-
AbstractUnfilteredRowIterator
protected AbstractUnfilteredRowIterator(TableMetadata metadata, DecoratedKey partitionKey, DeletionTime partitionLevelDeletion, RegularAndStaticColumns columns, Row staticRow, boolean isReverseOrder, EncodingStats stats)
-
-
Method Detail
-
metadata
public TableMetadata metadata()
Description copied from interface:BaseRowIterator
The metadata for the table this iterator on.- Specified by:
metadata
in interfaceBaseRowIterator<Unfiltered>
-
columns
public RegularAndStaticColumns columns()
Description copied from interface:BaseRowIterator
A subset of the columns for the (static and regular) rows returned by this iterator. Every row returned by this iterator must guarantee that it has only those columns.- Specified by:
columns
in interfaceBaseRowIterator<Unfiltered>
-
isReverseOrder
public boolean isReverseOrder()
Description copied from interface:BaseRowIterator
Whether or not the rows returned by this iterator are in reversed clustering order.- Specified by:
isReverseOrder
in interfaceBaseRowIterator<Unfiltered>
-
partitionKey
public DecoratedKey partitionKey()
Description copied from interface:BaseRowIterator
The partition key of the partition this in an iterator over.- Specified by:
partitionKey
in interfaceBaseRowIterator<Unfiltered>
-
partitionLevelDeletion
public DeletionTime partitionLevelDeletion()
Description copied from interface:UnfilteredRowIterator
The partition level deletion for the partition this iterate over.- Specified by:
partitionLevelDeletion
in interfaceUnfilteredRowIterator
-
staticRow
public Row staticRow()
Description copied from interface:BaseRowIterator
The static part corresponding to this partition (this can be an empty row but cannot benull
).- Specified by:
staticRow
in interfaceBaseRowIterator<Unfiltered>
-
stats
public EncodingStats stats()
Description copied from interface:UnfilteredRowIterator
Return "statistics" about what is returned by this iterator. Those are used for performance reasons (for delta-encoding for instance) and code should not expect those to be exact.- Specified by:
stats
in interfaceUnfilteredRowIterator
-
close
public void close()
- Specified by:
close
in interfacejava.lang.AutoCloseable
- Specified by:
close
in interfaceCloseableIterator<Unfiltered>
- Overrides:
close
in classAbstractIterator<Unfiltered>
-
-