Interface BucketAssigner.Context

    • Method Detail

      • currentProcessingTime

        long currentProcessingTime()
        Returns the current processing time.
      • currentWatermark

        long currentWatermark()
        Returns the current event-time watermark.
      • timestamp

        @Nullable
        Long timestamp()
        Returns the timestamp of the current input record or null if the element does not have an assigned timestamp.