Class ShortReadPartitionsProtection
- java.lang.Object
-
- org.apache.cassandra.db.transform.Transformation<UnfilteredRowIterator>
-
- org.apache.cassandra.service.reads.ShortReadPartitionsProtection
-
- All Implemented Interfaces:
MorePartitions<UnfilteredPartitionIterator>
public class ShortReadPartitionsProtection extends Transformation<UnfilteredRowIterator> implements MorePartitions<UnfilteredPartitionIterator>
-
-
Constructor Summary
Constructors Constructor Description ShortReadPartitionsProtection(ReadCommand command, Replica source, java.lang.Runnable preFetchCallback, DataLimits.Counter singleResultCounter, DataLimits.Counter mergedResultCounter, long queryStartNanoTime)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description UnfilteredRowIterator
applyToPartition(UnfilteredRowIterator partition)
Applied to any rows iterator (partition) we encounter in a partitions iteratorUnfilteredPartitionIterator
moreContents()
-
Methods inherited from class org.apache.cassandra.db.transform.Transformation
apply, apply, apply, apply, applyToDeletion, applyToMarker, applyToPartitionColumns, applyToPartitionKey, applyToRow, applyToStatic, onClose, onPartitionClose
-
-
-
-
Constructor Detail
-
ShortReadPartitionsProtection
public ShortReadPartitionsProtection(ReadCommand command, Replica source, java.lang.Runnable preFetchCallback, DataLimits.Counter singleResultCounter, DataLimits.Counter mergedResultCounter, long queryStartNanoTime)
-
-
Method Detail
-
applyToPartition
public UnfilteredRowIterator applyToPartition(UnfilteredRowIterator partition)
Description copied from class:Transformation
Applied to any rows iterator (partition) we encounter in a partitions iterator- Overrides:
applyToPartition
in classTransformation<UnfilteredRowIterator>
-
moreContents
public UnfilteredPartitionIterator moreContents()
-
-