public abstract class BlobStoreSegmentedParallelIterator extends Object implements DataIterator<BlobStoreGetBulkOperationResult>
Constructor and Description |
---|
BlobStoreSegmentedParallelIterator(int numSegments) |
Modifier and Type | Method and Description |
---|---|
void |
close()
Clean up after any resources associated with this iterator The iterator can be closed even if
the iterator wasn't iterated over all of its elements.
|
abstract DataIterator<BlobStoreGetBulkOperationResult> |
createDataIteratorForSegmen(int segmentNumber) |
BlockingQueue<Object> |
getObjectsQueue() |
Object |
getTerminationIndicator() |
boolean |
hasNext() |
BlobStoreGetBulkOperationResult |
next() |
void |
remove() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forEachRemaining
public BlobStoreSegmentedParallelIterator(int numSegments)
public BlobStoreGetBulkOperationResult next()
next
in interface Iterator<BlobStoreGetBulkOperationResult>
public boolean hasNext()
hasNext
in interface Iterator<BlobStoreGetBulkOperationResult>
public void close()
DataIterator
close
in interface DataIterator<BlobStoreGetBulkOperationResult>
public void remove()
remove
in interface Iterator<BlobStoreGetBulkOperationResult>
public Object getTerminationIndicator()
public BlockingQueue<Object> getObjectsQueue()
public abstract DataIterator<BlobStoreGetBulkOperationResult> createDataIteratorForSegmen(int segmentNumber)
Copyright © GigaSpaces.