Class BaseBroadcastProcessFunction.Context

    • Constructor Detail

      • Context

        public Context()
    • Method Detail

      • timestamp

        public abstract Long timestamp()
        Timestamp of the element currently being processed or timestamp of a firing timer.

        This might be null, depending on the stream's watermark strategy.

      • output

        public abstract <X> void output​(OutputTag<X> outputTag,
                                        X value)
        Emits a record to the side output identified by the OutputTag.
        Parameters:
        outputTag - the OutputTag that identifies the side output to emit to.
        value - The record to emit.
      • currentProcessingTime

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

        public abstract long currentWatermark()
        Returns the current event-time watermark.