Class ProcessJoinFunction.Context

  • Enclosing class:
    ProcessJoinFunction<IN1,​IN2,​OUT>

    public abstract class ProcessJoinFunction.Context
    extends Object
    The context that is available during an invocation of #processElement(Object, Object, Context, Collector). It gives access to the timestamps of the left element in the joined pair, the right one, and that of the joined pair. In addition, this context allows to emit elements on a side output.
    • Constructor Detail

      • Context

        public Context()
    • Method Detail

      • getLeftTimestamp

        public abstract long getLeftTimestamp()
        Returns:
        The timestamp of the left element of a joined pair
      • getRightTimestamp

        public abstract long getRightTimestamp()
        Returns:
        The timestamp of the right element of a joined pair
      • getTimestamp

        public abstract long getTimestamp()
        Returns:
        The timestamp of the joined pair.
      • 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 output tag that identifies the side output to emit to
        value - The record to emit