Package org.apache.cassandra.utils

Class MergeIterator.Candidate<In>

java.lang.Object

org.apache.cassandra.utils.MergeIterator.Candidate<In>

All Implemented Interfaces:

Comparable<MergeIterator.Candidate<In>>

Enclosing class:

MergeIterator<In,Out>

protected static final class MergeIterator.Candidate<In>
extends Object
implements Comparable<MergeIterator.Candidate<In>>

Constructor Summary

Constructors

Constructor	Description
Candidate(int idx, Iterator<? extends In> iter, Comparator<? super In> comp)

Method Summary

Modifier and Type	Method	Description
protected MergeIterator.Candidate<In>	advance()
int	compareTo(MergeIterator.Candidate<In> that)
<Out> void	consume(MergeIterator.Reducer<In,Out> reducer)
boolean	needsAdvance()

Methods inherited from class java.lang.Object

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

Constructor Details

Candidate

public Candidate(int idx,
 Iterator<? extends In> iter,
 Comparator<? super In> comp)

Method Details

advance

protected MergeIterator.Candidate<In> advance()

Returns:

this if our iterator had an item, and it is now available, otherwise null

compareTo

public int compareTo(MergeIterator.Candidate<In> that)

Specified by:

compareTo in interface Comparable<In>

consume

public <Out> void consume(MergeIterator.Reducer<In,Out> reducer)

needsAdvance

public boolean needsAdvance()