Package org.apache.cassandra.db.partitions

Class UnfilteredPartitionIterators

java.lang.Object

org.apache.cassandra.db.partitions.UnfilteredPartitionIterators

public abstract class UnfilteredPartitionIterators
extends 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

Modifier and Type	Method	Description
static UnfilteredPartitionIterator	concat(List<UnfilteredPartitionIterator> iterators)
static void	digest(UnfilteredPartitionIterator iterator, Digest digest, int version)	Digests the the provided iterator.
static PartitionIterator	filter(UnfilteredPartitionIterator iterator, long nowInSec)
static UnfilteredRowIterator	getOnlyElement(UnfilteredPartitionIterator iter, SinglePartitionReadCommand command)
static UnfilteredPartitionIterator	loggingIterator(UnfilteredPartitionIterator iterator, String id, boolean fullDetails)	Wraps the provided iterator so it logs the returned rows/RT for debugging purposes.
static UnfilteredPartitionIterator	merge(List<? extends UnfilteredPartitionIterator> iterators, UnfilteredPartitionIterators.MergeListener listener)
static UnfilteredPartitionIterator	mergeLazily(List<? extends UnfilteredPartitionIterator> iterators)
static UnfilteredPartitionIterators.Serializer	serializerForIntraNode()

Methods inherited from class java.lang.Object

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

Method Details

getOnlyElement

public static UnfilteredRowIterator getOnlyElement(UnfilteredPartitionIterator iter,
 SinglePartitionReadCommand command)

concat

public static UnfilteredPartitionIterator concat(List<UnfilteredPartitionIterator> iterators)

filter

public static PartitionIterator filter(UnfilteredPartitionIterator iterator,
 long nowInSec)

merge

public static UnfilteredPartitionIterator merge(List<? extends UnfilteredPartitionIterator> iterators,
 UnfilteredPartitionIterators.MergeListener listener)

mergeLazily

public static UnfilteredPartitionIterator mergeLazily(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 - the Digest 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,
 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.