Interface PartitionCommitPredicate.PredicateContext
-
- Enclosing interface:
- PartitionCommitPredicate
public static interface PartitionCommitPredicate.PredicateContextContext thatPartitionCommitPredicatecan use for getting context about a partition.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description longcreateProcTime()Return the creation time of the partition.longcurrentProcTime()Return the current process time.longcurrentWatermark()Returns the current event-time watermark.Stringpartition()Return the partition.
-
-
-
Method Detail
-
partition
String partition()
Return the partition.
-
createProcTime
long createProcTime()
Return the creation time of the partition.
-
currentProcTime
long currentProcTime()
Return the current process time.
-
currentWatermark
long currentWatermark()
Returns the current event-time watermark.
-
-