com.bigdata.striterator.ChunkedArrayIterator<E>
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Object
public class ChunkedArrayIterator<E>
Fully buffered iterator.
| Field Summary |
|---|
| Fields inherited from interface com.bigdata.striterator.IChunkedIterator |
|---|
DEFAULT_CHUNK_SIZE |
| Constructor Summary | |
|---|---|
ChunkedArrayIterator(E[] a)
An iterator that visits the elements in the given array. |
|
ChunkedArrayIterator(int n,
E[] a,
IKeyOrder<E> keyOrder)
An iterator that visits the elements in the given array. |
|
| Method Summary | |
|---|---|
E[] |
array()
Return the backing array. |
void |
close()
Closes the iterator, releasing any associated resources. |
int |
getBufferCount()
The #of elements that this iterator buffered. |
IKeyOrder<E> |
getKeyOrder()
The natural order in which elements are being visited. |
boolean |
hasNext()
|
E |
next()
The next element available from the iterator. |
E[] |
nextChunk()
Returns the remaining statements. |
E[] |
nextChunk(IKeyOrder<E> keyOrder)
Return the next "chunk" of elements. |
void |
remove()
Removes the last element visited by IChunkedIterator.next() (optional operation). |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
public ChunkedArrayIterator(E[] a)
a - The array of elements.
public ChunkedArrayIterator(int n,
E[] a,
IKeyOrder<E> keyOrder)
a - The array of elements.n - The #of entries in a that are valid.keyOrder - The order of the elements in the buffer or null
iff not known.| Method Detail |
|---|
public int getBufferCount()
public boolean hasNext()
hasNext in interface Iterator<E>public E next()
IChunkedIterator
next in interface IChunkedIterator<E>next in interface Iterator<E>public void remove()
IChunkedIteratorIChunkedIterator.next() (optional operation).
Note: This method is not readily suited for use with IChunkedIterator.nextChunk()
since the latter has already visited everything in the chunk and
IChunkedIterator.remove() would only remove the last item in the chunk. Normally
you will want to accumulate items to be removed in a buffer and then
submit the buffer to some batch api operation when it overflows.
Alternatively, the IRangeQuery.REMOVEALL flag may be used with
the source iterator to remove elements from the index as they are
visited.
remove in interface IChunkedIterator<E>remove in interface Iterator<E>UnsupportedOperationExceptionpublic E[] array()
getBufferCount()public E[] nextChunk()
nextChunk in interface IChunkedIterator<E>NoSuchElementException - if hasNext() returns false.public IKeyOrder<E> getKeyOrder()
IChunkedOrderedIterator
getKeyOrder in interface IChunkedOrderedIterator<E>null if not known.public E[] nextChunk(IKeyOrder<E> keyOrder)
IChunkedOrderedIteratorIChunkedOrderedIterator.getKeyOrder() would return non-null
and the request order corresponds to the value that would be returned by
IChunkedOrderedIterator.getKeyOrder() then the elements in the next chunk are NOT
sorted. Otherwise the elements in the next chunk are sorted before they
are returned. The size of the chunk is up to the implementation.
nextChunk in interface IChunkedOrderedIterator<E>keyOrder - The natural order for the elements in the chunk.
public void close()
ICloseableIteratorICloseableIterator.close() if Iterator.hasNext()
method returns false to ensure that the iterator is closed
(and its resources release) as soon as it is exhausted.
Note: Implementations that support Iterator.remove() MUST NOT
eagerly close the iterator when it is exhausted since that would make it
impossible to remove the last visited statement. Instead they MUST wait
for an explicit ICloseableIterator.close() by the application.
close in interface ICloseableIterator<E>
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||