Package org.apache.flink.datastream.impl.context

Class DefaultRuntimeContext

java.lang.Object

org.apache.flink.datastream.impl.context.DefaultRuntimeContext

All Implemented Interfaces:

RuntimeContext

public class DefaultRuntimeContext
extends Object
implements RuntimeContext

The default implementation of RuntimeContext.

Constructor Summary

Constructors

Constructor	Description
DefaultRuntimeContext(String jobName, JobType jobType, int parallelism, int maxParallelism, String taskName, MetricGroup metricGroup)

Method Summary

Modifier and Type	Method	Description
JobInfo	getJobInfo()	Get the JobInfo of this process function.
MetricGroup	getMetricGroup()	Get the metric group of this process function.
TaskInfo	getTaskInfo()	Get the TaskInfo of this process function.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DefaultRuntimeContext

public DefaultRuntimeContext(String jobName,
                             JobType jobType,
                             int parallelism,
                             int maxParallelism,
                             String taskName,
                             MetricGroup metricGroup)

Method Detail

getJobInfo

public JobInfo getJobInfo()

Description copied from interface: RuntimeContext

Get the JobInfo of this process function.

Specified by:

getJobInfo in interface RuntimeContext

getTaskInfo

public TaskInfo getTaskInfo()

Description copied from interface: RuntimeContext

Get the TaskInfo of this process function.

Specified by:

getTaskInfo in interface RuntimeContext

getMetricGroup

public MetricGroup getMetricGroup()

Description copied from interface: RuntimeContext

Get the metric group of this process function.

Specified by:

getMetricGroup in interface RuntimeContext