org.apache.flink.datastream.impl.context

类 DefaultRuntimeContext

java.lang.Object

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

所有已实现的接口:

org.apache.flink.datastream.api.context.RuntimeContext

public class DefaultRuntimeContext
extends Object
implements org.apache.flink.datastream.api.context.RuntimeContext

The default implementation of RuntimeContext.

构造器概要

构造器

构造器和说明
DefaultRuntimeContext(String jobName, org.apache.flink.runtime.jobgraph.JobType jobType, int parallelism, int maxParallelism, String taskName, org.apache.flink.metrics.MetricGroup metricGroup)

方法概要

限定符和类型	方法和说明
org.apache.flink.datastream.api.context.JobInfo	getJobInfo()
org.apache.flink.metrics.MetricGroup	getMetricGroup()
org.apache.flink.datastream.api.context.TaskInfo	getTaskInfo()

从类继承的方法 java.lang.Object

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

构造器详细资料

DefaultRuntimeContext

public DefaultRuntimeContext(String jobName,
                             org.apache.flink.runtime.jobgraph.JobType jobType,
                             int parallelism,
                             int maxParallelism,
                             String taskName,
                             org.apache.flink.metrics.MetricGroup metricGroup)

方法详细资料

getJobInfo

public org.apache.flink.datastream.api.context.JobInfo getJobInfo()

指定者:

getJobInfo 在接口中 org.apache.flink.datastream.api.context.RuntimeContext

getTaskInfo

public org.apache.flink.datastream.api.context.TaskInfo getTaskInfo()

指定者:

getTaskInfo 在接口中 org.apache.flink.datastream.api.context.RuntimeContext

getMetricGroup

public org.apache.flink.metrics.MetricGroup getMetricGroup()

指定者:

getMetricGroup 在接口中 org.apache.flink.datastream.api.context.RuntimeContext