Package org.apache.cassandra.db.transform

Class RTBoundValidator

java.lang.Object

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

org.apache.cassandra.db.transform.RTBoundValidator

public final class RTBoundValidator
extends Transformation<UnfilteredRowIterator>

A validating transformation that sanity-checks the sequence of RT bounds and boundaries in every partition. What we validate, specifically: - that open markers are only followed by close markers - that open markers and close markers have equal deletion times - optionally, that the iterator closes its last RT marker

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	RTBoundValidator.Stage

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	validate(UnfilteredPartitionIterator partitions, RTBoundValidator.Stage stage, boolean enforceIsClosed)
static UnfilteredRowIterator	validate(UnfilteredRowIterator partition, RTBoundValidator.Stage stage, boolean enforceIsClosed)

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

validate

public static UnfilteredPartitionIterator validate(UnfilteredPartitionIterator partitions,
 RTBoundValidator.Stage stage,
 boolean enforceIsClosed)

validate

public static UnfilteredRowIterator validate(UnfilteredRowIterator partition,
 RTBoundValidator.Stage stage,
 boolean enforceIsClosed)

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>