Package org.apache.cassandra.service.reads.repair

Class PartitionIteratorMergeListener<E extends Endpoints<E>>

java.lang.Object

org.apache.cassandra.service.reads.repair.PartitionIteratorMergeListener<E>

All Implemented Interfaces:

UnfilteredPartitionIterators.MergeListener

public class PartitionIteratorMergeListener<E extends Endpoints<E>>
extends Object
implements UnfilteredPartitionIterators.MergeListener

Field Summary

Fields inherited from interface org.apache.cassandra.db.partitions.UnfilteredPartitionIterators.MergeListener

NOOP

Constructor Summary

Constructors

Constructor	Description
PartitionIteratorMergeListener(ReplicaPlan.ForRead<E,?> replicaPlan, ReadCommand command, ReadRepair readRepair)

Method Summary

Modifier and Type	Method	Description
void	close()
static RegularAndStaticColumns	columns(List<UnfilteredRowIterator> versions)
UnfilteredRowIterators.MergeListener	getRowMergeListener(DecoratedKey partitionKey, List<UnfilteredRowIterator> versions)
protected boolean	isReversed(List<UnfilteredRowIterator> versions)

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.cassandra.db.partitions.UnfilteredPartitionIterators.MergeListener

preserveOrder

Constructor Details

PartitionIteratorMergeListener

public PartitionIteratorMergeListener(ReplicaPlan.ForRead<E,?> replicaPlan,
 ReadCommand command,
 ReadRepair readRepair)

Method Details

getRowMergeListener

public UnfilteredRowIterators.MergeListener getRowMergeListener(DecoratedKey partitionKey,
 List<UnfilteredRowIterator> versions)

Specified by:

getRowMergeListener in interface UnfilteredPartitionIterators.MergeListener

columns

public static RegularAndStaticColumns columns(List<UnfilteredRowIterator> versions)

isReversed

protected boolean isReversed(List<UnfilteredRowIterator> versions)

close

public void close()

Specified by:

close in interface UnfilteredPartitionIterators.MergeListener