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