public interface ParallelScanIterator<K> extends Iterator<K>
Parallel Scan version
of storeIterator().
This Iterator adds the ability to close (terminate) a ParallelScan as well gather per-partition and per-shard statistics about the scan.
Iterators implementing this interface can only be used safely by one thread at a time unless synchronized externally.
Modifier and Type | Method and Description |
---|---|
void |
close()
Close (terminate) a Parallel Scan.
|
List<DetailedMetrics> |
getPartitionMetrics()
Gets the per-partition metrics for this Parallel Scan.
|
List<DetailedMetrics> |
getShardMetrics()
Gets the per-shard metrics for this Parallel Scan.
|
K |
next()
Returns the next element in the iteration.
|
forEachRemaining, hasNext, remove
void close()
List<DetailedMetrics> getPartitionMetrics()
List<DetailedMetrics> getShardMetrics()
K next()
next
in interface Iterator<K>
NoSuchElementException
- - iteration has no more elements.StoreIteratorException
- - an exception occurred during a
retrieval as part of a multi-record iteration method. This exception
does not necessarily close or invalidate the iterator. Repeated calls to
next() may or may not cause an exception to be thrown. It is incumbent
on the caller to determine the type of exception and act accordingly.Copyright (c) 2011, 2017 Oracle and/or its affiliates. All rights reserved.