Package org.apache.cassandra.service.reads

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, Dispatcher.RequestTime requestTime)

Method Summary

Modifier and Type	Method	Description
UnfilteredRowIterator	applyToPartition(UnfilteredRowIterator partition)	Applied to any rows iterator (partition) we encounter in a partitions iterator
UnfilteredPartitionIterator	moreContents()

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

apply, apply, apply, apply, applyToDeletion, applyToMarker, applyToPartitionColumns, applyToPartitionKey, applyToRow, applyToStatic, onClose, onPartitionClose

Methods inherited from class java.lang.Object

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

Constructor Detail

ShortReadPartitionsProtection

public ShortReadPartitionsProtection(ReadCommand command,
                                     Replica source,
                                     java.lang.Runnable preFetchCallback,
                                     DataLimits.Counter singleResultCounter,
                                     DataLimits.Counter mergedResultCounter,
                                     Dispatcher.RequestTime requestTime)

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 class Transformation<UnfilteredRowIterator>

moreContents

public UnfilteredPartitionIterator moreContents()