Package | Description |
---|---|
org.apache.hadoop.mapred.join | |
org.apache.hadoop.mapreduce.lib.join |
Modifier and Type | Interface and Description |
---|---|
interface |
ResetableIterator<T extends Writable>
This defines an interface to a stateful Iterator that can replay elements
added to it directly.
|
Modifier and Type | Class and Description |
---|---|
class |
ArrayListBackedIterator<X extends Writable>
This class provides an implementation of ResetableIterator.
|
class |
StreamBackedIterator<X extends Writable>
This class provides an implementation of ResetableIterator.
|
Modifier and Type | Method and Description |
---|---|
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.
|
Copyright © 2017 Apache Software Foundation. All rights reserved.