public abstract class UnfilteredPartitionIterators
extends java.lang.Object
Modifier and Type | Class and 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.
|
public static UnfilteredRowIterator getOnlyElement(UnfilteredPartitionIterator iter, SinglePartitionReadCommand command)
public static UnfilteredPartitionIterator concat(java.util.List<UnfilteredPartitionIterator> iterators)
public static PartitionIterator filter(UnfilteredPartitionIterator iterator, int nowInSec)
public static UnfilteredPartitionIterator merge(java.util.List<? extends UnfilteredPartitionIterator> iterators, int nowInSec, UnfilteredPartitionIterators.MergeListener listener)
public static UnfilteredPartitionIterator mergeLazily(java.util.List<? extends UnfilteredPartitionIterator> iterators, int nowInSec)
public static void digest(ReadCommand command, UnfilteredPartitionIterator iterator, java.security.MessageDigest digest, int version)
command
- the command that has yield iterator
. This can be null if version >= MessagingService.VERSION_30
as this is only used when producing digest to be sent to legacy nodes.iterator
- the iterator to digest.digest
- the MessageDigest
to use for the digest.version
- the messaging protocol to use when producing the digest.public static UnfilteredPartitionIterators.Serializer serializerForIntraNode()
public static UnfilteredPartitionIterator loggingIterator(UnfilteredPartitionIterator iterator, java.lang.String id, boolean fullDetails)
Note that this is only meant for debugging as this can log a very large amount of logging at INFO.
Copyright © 2020 The Apache Software Foundation