public class DuplicateRowChecker extends Transformation<BaseRowIterator<?>>
| Modifier and Type | Method and 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,
java.util.List<java.net.InetAddress> 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
|
apply, apply, apply, apply, applyToPartition, applyToPartitionColumns, applyToPartitionKey, onCloseprotected DeletionTime applyToDeletion(DeletionTime deletionTime)
TransformationapplyToDeletion in class Transformation<BaseRowIterator<?>>protected RangeTombstoneMarker applyToMarker(RangeTombstoneMarker marker)
TransformationapplyToMarker in class Transformation<BaseRowIterator<?>>protected Row applyToStatic(Row row)
TransformationapplyToStatic in class Transformation<BaseRowIterator<?>>protected Row applyToRow(Row row)
TransformationapplyToRow in class Transformation<BaseRowIterator<?>>protected void onPartitionClose()
TransformationonPartitionClose in class Transformation<BaseRowIterator<?>>public static UnfilteredPartitionIterator duringCompaction(UnfilteredPartitionIterator iterator, OperationType type)
public static PartitionIterator duringRead(PartitionIterator iterator, java.util.List<java.net.InetAddress> replicas)
Copyright © 2009-2022 The Apache Software Foundation