Interface PartitionCommitPredicate.PredicateContext

    • 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.