Package oracle.kv
Interface IterationSubscription
-
- All Superinterfaces:
org.reactivestreams.Subscription
- All Known Subinterfaces:
ExecutionSubscription
public interface IterationSubscription extends org.reactivestreams.Subscription
A subinterface ofSubscription
implemented by subscriptions supplied when aSubscriber
subscribes to aPublisher
associated with an asynchronous table iteration.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description List<DetailedMetrics>
getPartitionMetrics()
Returns per-partition metrics for the iteration.List<DetailedMetrics>
getShardMetrics()
Returns per-shard metrics for the iteration.
-
-
-
Method Detail
-
getPartitionMetrics
List<DetailedMetrics> getPartitionMetrics()
Returns per-partition metrics for the iteration. This method may be called at any time during an iteration in order to obtain metrics to that point or it may be called at the end to obtain metrics for the entire scan. If there are no metrics available yet for a particular partition, then that partition will not have an entry in the list.- Returns:
- the per-partition metrics for iteration
-
getShardMetrics
List<DetailedMetrics> getShardMetrics()
Returns per-shard metrics for the iteration. This method may be called at any time during an iteration in order to obtain metrics to that point or it may be called at the end to obtain metrics for the entire scan. If there are no metrics available yet for a particular shard, then that shard will not have an entry in the list.- Returns:
- the per-shard metrics for the iteration
-
-