Package org.apache.cassandra.utils

Class MergeIterator<In,Out>

java.lang.Object

org.apache.cassandra.utils.AbstractIterator<Out>

org.apache.cassandra.utils.MergeIterator<In,Out>

All Implemented Interfaces:

com.google.common.collect.PeekingIterator<Out>, AutoCloseable, Iterator<Out>, CloseableIterator<Out>, IMergeIterator<In,Out>

public abstract class MergeIterator<In,Out>
extends AbstractIterator<Out>
implements IMergeIterator<In,Out>

Merges sorted input iterators which individually contain unique items.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
protected static final class	MergeIterator.Candidate<In>
static class	MergeIterator.Reducer<In,Out>	Accumulator that collects values of type A, and outputs a value of type B.

Field Summary

Fields

Modifier and Type	Field	Description
protected final List<? extends Iterator<In>>	iterators
protected final MergeIterator.Reducer<In,Out>	reducer

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	MergeIterator(List<? extends Iterator<In>> iters, MergeIterator.Reducer<In,Out> reducer)

Method Summary

Modifier and Type	Method	Description
void	close()
static <In, Out> MergeIterator<In,Out>	get(List<? extends Iterator<In>> sources, Comparator<? super In> comparator, MergeIterator.Reducer<In,Out> reducer)
Iterable<? extends Iterator<In>>	iterators()

Methods inherited from class org.apache.cassandra.utils.AbstractIterator

computeNext, endOfData, hasNext, next, peek, remove

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.Iterator

forEachRemaining, hasNext

Field Details

reducer

protected final MergeIterator.Reducer<In,Out> reducer

iterators

protected final List<? extends Iterator<In>> iterators

Constructor Details

MergeIterator

protected MergeIterator(List<? extends Iterator<In>> iters,
 MergeIterator.Reducer<In,Out> reducer)

Method Details

get

public static <In,
Out> MergeIterator<In,Out> get(List<? extends Iterator<In>> sources,
 Comparator<? super In> comparator,
 MergeIterator.Reducer<In,Out> reducer)

iterators

public Iterable<? extends Iterator<In>> iterators()

Specified by:

iterators in interface IMergeIterator<In,Out>

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface CloseableIterator<In>

Overrides:

close in class AbstractIterator<Out>