Package org.apache.cassandra.metrics

Class TopPartitionTracker.TombstoneCounter

java.lang.Object

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

org.apache.cassandra.metrics.TopPartitionTracker.TombstoneCounter

Enclosing class:

TopPartitionTracker

public static class TopPartitionTracker.TombstoneCounter
extends Transformation<UnfilteredRowIterator>

Constructor Summary

Constructors

Constructor	Description
TombstoneCounter(TopPartitionTracker.Collector collector, int nowInSec)

Method Summary

Modifier and Type	Method	Description
RangeTombstoneMarker	applyToMarker(RangeTombstoneMarker marker)	Applied to any RTM we encounter in a rows/unfiltered iterator
protected UnfilteredRowIterator	applyToPartition(UnfilteredRowIterator partition)	Applied to any rows iterator (partition) we encounter in a partitions iterator
Row	applyToRow(Row row)	Applied to any row we encounter in a rows iterator
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, applyToDeletion, applyToPartitionColumns, applyToPartitionKey, applyToStatic, onClose

Methods inherited from class java.lang.Object

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

Constructor Detail

TombstoneCounter

public TombstoneCounter(TopPartitionTracker.Collector collector,
                        int nowInSec)

Method Detail

applyToRow

public Row applyToRow(Row row)

Description copied from class: Transformation

Applied to any row we encounter in a rows iterator

Overrides:

applyToRow in class Transformation<UnfilteredRowIterator>

applyToMarker

public 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<UnfilteredRowIterator>

applyToPartition

protected 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>

onPartitionClose

public 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<UnfilteredRowIterator>