Package org.apache.cassandra.db
Class ReadCommand.CheckForAbort
- java.lang.Object
-
- org.apache.cassandra.db.transform.Transformation<I>
-
- org.apache.cassandra.db.transform.StoppingTransformation<UnfilteredRowIterator>
-
- org.apache.cassandra.db.ReadCommand.CheckForAbort
-
- Enclosing class:
- ReadCommand
protected class ReadCommand.CheckForAbort extends StoppingTransformation<UnfilteredRowIterator>
-
-
Field Summary
-
Fields inherited from class org.apache.cassandra.db.transform.StoppingTransformation
partitions, rows
-
-
Constructor Summary
Constructors Modifier Constructor Description protectedCheckForAbort()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected UnfilteredRowIteratorapplyToPartition(UnfilteredRowIterator partition)Applied to any rows iterator (partition) we encounter in a partitions iteratorprotected RowapplyToRow(Row row)Applied to any row we encounter in a rows iteratorprotected voidattachTo(BasePartitions partitions)protected voidattachTo(BaseRows rows)-
Methods inherited from class org.apache.cassandra.db.transform.StoppingTransformation
onClose, onPartitionClose, stop, stopInPartition
-
Methods inherited from class org.apache.cassandra.db.transform.Transformation
apply, apply, apply, apply, applyToDeletion, applyToMarker, applyToPartitionColumns, applyToPartitionKey, applyToStatic
-
-
-
-
Method Detail
-
attachTo
protected void attachTo(BasePartitions partitions)
- Overrides:
attachToin classStoppingTransformation<UnfilteredRowIterator>
-
attachTo
protected void attachTo(BaseRows rows)
- Overrides:
attachToin classStoppingTransformation<UnfilteredRowIterator>
-
applyToPartition
protected UnfilteredRowIterator applyToPartition(UnfilteredRowIterator partition)
Description copied from class:TransformationApplied to any rows iterator (partition) we encounter in a partitions iterator- Overrides:
applyToPartitionin classTransformation<UnfilteredRowIterator>
-
applyToRow
protected Row applyToRow(Row row)
Description copied from class:TransformationApplied to any row we encounter in a rows iterator- Overrides:
applyToRowin classTransformation<UnfilteredRowIterator>
-
-