Package org.apache.cassandra.db.transform

Class DuplicateRowChecker

java.lang.Object

org.apache.cassandra.db.transform.Transformation<BaseRowIterator<?>>

org.apache.cassandra.db.transform.DuplicateRowChecker

public class DuplicateRowChecker
extends Transformation<BaseRowIterator<?>>

Method Summary

Modifier and Type	Method	Description
protected DeletionTime	applyToDeletion(DeletionTime deletionTime)	Applied to the partition-level deletion of any rows iterator.
protected RangeTombstoneMarker	applyToMarker(RangeTombstoneMarker marker)	Applied to any RTM we encounter in a rows/unfiltered iterator
protected Row	applyToRow(Row row)	Applied to any row we encounter in a rows iterator
protected Row	applyToStatic(Row row)	Applied to the static row of any rows iterator.
static UnfilteredPartitionIterator	duringCompaction(UnfilteredPartitionIterator iterator, OperationType type)
static PartitionIterator	duringRead(PartitionIterator iterator, List<InetAddressAndPort> replicas)
protected void	onPartitionClose()	Run on the close of any (logical) rows iterator this function was applied to We stipulate logical, because if applied to a transformed iterator the lifetime of the iterator object may be longer than the lifetime of the "logical" iterator it was applied to; if the iterator is refilled with MoreContents, for instance, the iterator may outlive this function

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

apply, apply, apply, apply, applyToPartition, applyToPartitionColumns, applyToPartitionKey, onClose

Methods inherited from class java.lang.Object

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

Method Details

applyToDeletion

protected DeletionTime applyToDeletion(DeletionTime deletionTime)

Description copied from class: Transformation

Applied to the partition-level deletion of any rows iterator. NOTE that this is only applied to the first iterator in any sequence of iterators filled by a MoreContents; the static data for such iterators is all expected to be equal

Overrides:

applyToDeletion in class Transformation<BaseRowIterator<?>>

applyToMarker

protected RangeTombstoneMarker applyToMarker(RangeTombstoneMarker marker)

Description copied from class: Transformation

Applied to any RTM we encounter in a rows/unfiltered iterator

Overrides:

applyToMarker in class Transformation<BaseRowIterator<?>>

applyToStatic

protected Row applyToStatic(Row row)

Description copied from class: Transformation

Applied to the static row of any rows iterator. NOTE that this is only applied to the first iterator in any sequence of iterators filled by a MoreContents; the static data for such iterators is all expected to be equal

Overrides:

applyToStatic in class Transformation<BaseRowIterator<?>>

applyToRow

protected Row applyToRow(Row row)

Description copied from class: Transformation

Applied to any row we encounter in a rows iterator

Overrides:

applyToRow in class Transformation<BaseRowIterator<?>>

onPartitionClose

protected void onPartitionClose()

Description copied from class: Transformation

Run on the close of any (logical) rows iterator this function was applied to We stipulate logical, because if applied to a transformed iterator the lifetime of the iterator object may be longer than the lifetime of the "logical" iterator it was applied to; if the iterator is refilled with MoreContents, for instance, the iterator may outlive this function

Overrides:

onPartitionClose in class Transformation<BaseRowIterator<?>>

duringCompaction

public static UnfilteredPartitionIterator duringCompaction(UnfilteredPartitionIterator iterator,
 OperationType type)

duringRead

public static PartitionIterator duringRead(PartitionIterator iterator,
 List<InetAddressAndPort> replicas)