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 java.lang.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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
close()
protected RegularAndStaticColumns
columns(java.util.List<UnfilteredRowIterator> versions)
UnfilteredRowIterators.MergeListener
getRowMergeListener(DecoratedKey partitionKey, java.util.List<UnfilteredRowIterator> versions)
protected boolean
isReversed(java.util.List<UnfilteredRowIterator> versions)
-
-
-
Constructor Detail
-
PartitionIteratorMergeListener
public PartitionIteratorMergeListener(ReplicaPlan.ForRead<E> replicaPlan, ReadCommand command, ReadRepair readRepair)
-
-
Method Detail
-
getRowMergeListener
public UnfilteredRowIterators.MergeListener getRowMergeListener(DecoratedKey partitionKey, java.util.List<UnfilteredRowIterator> versions)
- Specified by:
getRowMergeListener
in interfaceUnfilteredPartitionIterators.MergeListener
-
columns
protected RegularAndStaticColumns columns(java.util.List<UnfilteredRowIterator> versions)
-
isReversed
protected boolean isReversed(java.util.List<UnfilteredRowIterator> versions)
-
close
public void close()
- Specified by:
close
in interfaceUnfilteredPartitionIterators.MergeListener
-
-