oracle.kv

Interface ParallelScanIterator<K>

All Superinterfaces:

Iterator<K>

public interface ParallelScanIterator<K>
extends Iterator<K>

Interface to the specialized Iterator type returned by the 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.

Method Summary

Methods

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.

Methods inherited from interface java.util.Iterator

hasNext, next, remove

Method Detail

close

void close()

Close (terminate) a Parallel Scan. This shutdowns down all related threads and tasks, but does not await termination before returning.

getPartitionMetrics

List<DetailedMetrics> getPartitionMetrics()

Gets the per-partition metrics for this Parallel Scan. This may be called at any time during the iteration in order to obtain metrics to that point or it may be called at the end to obtain metrics for the entire scan.

Returns:

the per-partition metrics for this Parallel Scan.

getShardMetrics

List<DetailedMetrics> getShardMetrics()

Gets the per-shard metrics for this Parallel Scan. This may be called at any time during the iteration in order to obtain metrics to that point or it may be called at the end to obtain metrics for the entire scan.

Returns:

the per-shard metrics for this Parallel Scan.