Interface RuntimeContext

  • All Known Subinterfaces:
    NonPartitionedContext<OUT>, PartitionedContext, TwoOutputNonPartitionedContext<OUT1,​OUT2>

    @Experimental
    public interface RuntimeContext
    A RuntimeContext contains information about the context in which process functions are executed.

    Each parallel instance of the function will have a context through which it can access contextual information.

    • Method Detail

      • getJobInfo

        JobInfo getJobInfo()
        Get the JobInfo of this process function.
      • getTaskInfo

        TaskInfo getTaskInfo()
        Get the TaskInfo of this process function.
      • getMetricGroup

        org.apache.flink.metrics.MetricGroup getMetricGroup()
        Get the metric group of this process function.