Package org.apache.cassandra.db.transform

Class RTBoundCloser

java.lang.Object

org.apache.cassandra.db.transform.Transformation<UnfilteredRowIterator>

org.apache.cassandra.db.transform.RTBoundCloser

public final class RTBoundCloser
extends Transformation<UnfilteredRowIterator>

A transformation that appends an RT bound marker to row iterators in case they don't have one. This used to happen, for example, in ReadCommand.executeLocally(ReadExecutionController) if DataLimits stopped the iterator on a live row that was enclosed in an older RT. If we don't do this, and send a response without the closing bound, we can break read/short read protection read isolation, and potentially cause data loss. See CASSANDRA-14515 for context.

Method Summary

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

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

Method Details

close

public static UnfilteredPartitionIterator close(UnfilteredPartitionIterator partitions)

close

public static UnfilteredRowIterator close(UnfilteredRowIterator partition)

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>