Class UnfilteredPartitionIterators
- java.lang.Object
-
- org.apache.cassandra.db.partitions.UnfilteredPartitionIterators
-
public abstract class UnfilteredPartitionIterators extends java.lang.Object
Static methods to work with partition iterators.
-
-
Nested Class Summary
Nested Classes Modifier and Type Class Description static interface
UnfilteredPartitionIterators.MergeListener
static class
UnfilteredPartitionIterators.Serializer
Serialize each UnfilteredSerializer one after the other, with an initial byte that indicates whether we're done or not.
-
Method Summary
-
-
-
Method Detail
-
getOnlyElement
public static UnfilteredRowIterator getOnlyElement(UnfilteredPartitionIterator iter, SinglePartitionReadCommand command)
-
concat
public static UnfilteredPartitionIterator concat(java.util.List<UnfilteredPartitionIterator> iterators)
-
filter
public static PartitionIterator filter(UnfilteredPartitionIterator iterator, int nowInSec)
-
merge
public static UnfilteredPartitionIterator merge(java.util.List<? extends UnfilteredPartitionIterator> iterators, UnfilteredPartitionIterators.MergeListener listener)
-
mergeLazily
public static UnfilteredPartitionIterator mergeLazily(java.util.List<? extends UnfilteredPartitionIterator> iterators)
-
digest
public static void digest(UnfilteredPartitionIterator iterator, Digest digest, int version)
Digests the the provided iterator. Caller must close the provided iterator.- Parameters:
iterator
- the iterator to digest.digest
- theDigest
to use.version
- the messaging protocol to use when producing the digest.
-
serializerForIntraNode
public static UnfilteredPartitionIterators.Serializer serializerForIntraNode()
-
loggingIterator
public static UnfilteredPartitionIterator loggingIterator(UnfilteredPartitionIterator iterator, java.lang.String id, boolean fullDetails)
Wraps the provided iterator so it logs the returned rows/RT for debugging purposes.Note that this is only meant for debugging as this can log a very large amount of logging at INFO.
-
-