|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.mapred.join.MultiFilterRecordReader.MultiFilterDelegationIterator
protected class MultiFilterRecordReader.MultiFilterDelegationIterator
Proxy the JoinCollector, but include callback to emit.
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface org.apache.hadoop.mapred.join.ResetableIterator |
---|
ResetableIterator.EMPTY<U extends Writable> |
Constructor Summary | |
---|---|
protected |
MultiFilterRecordReader.MultiFilterDelegationIterator()
|
Method Summary | |
---|---|
void |
add(V item)
Add an element to the collection of elements to iterate over. |
void |
clear()
Close datasources, but do not release internal resources. |
void |
close()
Close datasources and release resources. |
boolean |
hasNext()
True if a call to next may return a value. |
boolean |
next(V val)
Assign next value to actual. |
boolean |
replay(V val)
Assign last value returned to actual. |
void |
reset()
Set iterator to return to the start of its range. |
Methods inherited from class java.lang.Object |
---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Constructor Detail |
---|
protected MultiFilterRecordReader.MultiFilterDelegationIterator()
Method Detail |
---|
public boolean hasNext()
ResetableIterator
hasNext
in interface ResetableIterator<V extends Writable>
public boolean next(V val) throws IOException
ResetableIterator
ResetableIterator.reset()
(FIFO).
Note that a call to this may fail for nested joins (i.e. more elements
available, but none satisfying the constraints of the join)
next
in interface ResetableIterator<V extends Writable>
IOException
public boolean replay(V val) throws IOException
ResetableIterator
replay
in interface ResetableIterator<V extends Writable>
IOException
public void reset()
ResetableIterator
ResetableIterator.add(T)
to avoid a ConcurrentModificationException.
reset
in interface ResetableIterator<V extends Writable>
public void add(V item) throws IOException
ResetableIterator
add
in interface ResetableIterator<V extends Writable>
IOException
public void close() throws IOException
ResetableIterator
close
in interface ResetableIterator<V extends Writable>
IOException
public void clear()
ResetableIterator
clear
in interface ResetableIterator<V extends Writable>
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |