public class DefaultRuntimeContext extends Object implements RuntimeContext
RuntimeContext
.Constructor and Description |
---|
DefaultRuntimeContext(String jobName,
JobType jobType,
int parallelism,
int maxParallelism,
String taskName,
MetricGroup metricGroup) |
Modifier and Type | Method and 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. |
public DefaultRuntimeContext(String jobName, JobType jobType, int parallelism, int maxParallelism, String taskName, MetricGroup metricGroup)
public JobInfo getJobInfo()
RuntimeContext
JobInfo
of this process function.getJobInfo
in interface RuntimeContext
public TaskInfo getTaskInfo()
RuntimeContext
TaskInfo
of this process function.getTaskInfo
in interface RuntimeContext
public MetricGroup getMetricGroup()
RuntimeContext
getMetricGroup
in interface RuntimeContext
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.