Package cz.o2.proxima.core.storage
Interface ThroughputLimiter.Context
- 
- Enclosing interface:
- ThroughputLimiter
 
 public static interface ThroughputLimiter.ContextA context ofThroughputLimiter.getPauseTime(cz.o2.proxima.core.storage.ThroughputLimiter.Context)method.
- 
- 
Method SummaryAll Methods Instance Methods Abstract Methods Modifier and Type Method Description java.util.Collection<Partition>getConsumedPartitions()Get collection ofPartitionsassociated with reader reading with this limiterlonggetMinWatermark()Retrieve current reader's watermark (minimum of all partitions).
 
- 
- 
- 
Method Detail- 
getConsumedPartitionsjava.util.Collection<Partition> getConsumedPartitions() Get collection ofPartitionsassociated with reader reading with this limiter- Returns:
- list of associated partitions
 
 - 
getMinWatermarklong getMinWatermark() Retrieve current reader's watermark (minimum of all partitions).- Returns:
- minimal watermark within partitions
 
 
- 
 
-