|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.mapred.join.ArrayListBackedIterator<X>
public class ArrayListBackedIterator<X extends Writable>
This class provides an implementation of ResetableIterator. The
implementation uses an ArrayList
to store elements
added to it, replaying them as requested.
Prefer StreamBackedIterator
.
Nested Class Summary |
---|
Nested classes/interfaces inherited from interface org.apache.hadoop.mapred.join.ResetableIterator |
---|
ResetableIterator.EMPTY<U extends Writable> |
Constructor Summary | |
---|---|
ArrayListBackedIterator()
|
|
ArrayListBackedIterator(ArrayList<X> data)
|
Method Summary | |
---|---|
void |
add(X 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(X val)
Assign next value to actual. |
boolean |
replay(X 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 |
---|
public ArrayListBackedIterator()
public ArrayListBackedIterator(ArrayList<X> data)
Method Detail |
---|
public boolean hasNext()
ResetableIterator
hasNext
in interface ResetableIterator<X extends Writable>
public boolean next(X 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<X extends Writable>
IOException
public boolean replay(X val) throws IOException
ResetableIterator
replay
in interface ResetableIterator<X extends Writable>
IOException
public void reset()
ResetableIterator
ResetableIterator.add(T)
to avoid a ConcurrentModificationException.
reset
in interface ResetableIterator<X extends Writable>
public void add(X item) throws IOException
ResetableIterator
add
in interface ResetableIterator<X extends Writable>
IOException
public void close() throws IOException
ResetableIterator
close
in interface ResetableIterator<X extends Writable>
IOException
public void clear()
ResetableIterator
clear
in interface ResetableIterator<X extends Writable>
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |