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, UnfilteredPartitionIterators.MergeListener listener)
public static UnfilteredPartitionIterator mergeLazily(java.util.List<? extends UnfilteredPartitionIterator> iterators)
public static void digest(UnfilteredPartitionIterator iterator, Digest digest, int version)
iterator
- the iterator to digest.digest
- the Digest
to use.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 © 2009-2020 The Apache Software Foundation