|
||||||||||
PREV NEXT | FRAMES NO FRAMES |
Packages that use ResetableIterator | |
---|---|
org.apache.hadoop.mapred.join | Given a set of sorted datasets keyed with the same class and yielding equal partitions, it is possible to effect a join of those datasets prior to the map. |
Uses of ResetableIterator in org.apache.hadoop.mapred.join |
---|
Classes in org.apache.hadoop.mapred.join that implement ResetableIterator | |
---|---|
class |
ArrayListBackedIterator<X extends Writable>
This class provides an implementation of ResetableIterator. |
protected class |
JoinRecordReader.JoinDelegationIterator
Since the JoinCollector is effecting our operation, we need only provide an iterator proxy wrapping its operation. |
protected class |
MultiFilterRecordReader.MultiFilterDelegationIterator
Proxy the JoinCollector, but include callback to emit. |
static class |
ResetableIterator.EMPTY<U extends Writable>
|
class |
StreamBackedIterator<X extends Writable>
This class provides an implementation of ResetableIterator. |
Methods in org.apache.hadoop.mapred.join that return ResetableIterator | |
---|---|
protected ResetableIterator<TupleWritable> |
JoinRecordReader.getDelegate()
Return an iterator wrapping the JoinCollector. |
protected ResetableIterator<V> |
MultiFilterRecordReader.getDelegate()
Return an iterator returning a single value from the tuple. |
protected abstract ResetableIterator<X> |
CompositeRecordReader.getDelegate()
Obtain an iterator over the child RRs apropos of the value type ultimately emitted from this join. |
|
||||||||||
PREV NEXT | FRAMES NO FRAMES |