Class DefaultJobManagerJobMetricGroupFactory
- java.lang.Object
-
- org.apache.flink.runtime.jobmaster.factories.DefaultJobManagerJobMetricGroupFactory
-
- All Implemented Interfaces:
JobManagerJobMetricGroupFactory
public class DefaultJobManagerJobMetricGroupFactory extends Object implements JobManagerJobMetricGroupFactory
Default implementation ofJobManagerJobMetricGroupFactory
which creates for a givenExecutionPlan
aJobManagerJobMetricGroup
.
-
-
Constructor Summary
Constructors Constructor Description DefaultJobManagerJobMetricGroupFactory(JobManagerMetricGroup jobManagerMetricGroup)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description JobManagerJobMetricGroup
create(ExecutionPlan executionPlan)
Create a newJobManagerJobMetricGroup
.
-
-
-
Constructor Detail
-
DefaultJobManagerJobMetricGroupFactory
public DefaultJobManagerJobMetricGroupFactory(@Nonnull JobManagerMetricGroup jobManagerMetricGroup)
-
-
Method Detail
-
create
public JobManagerJobMetricGroup create(@Nonnull ExecutionPlan executionPlan)
Description copied from interface:JobManagerJobMetricGroupFactory
Create a newJobManagerJobMetricGroup
.- Specified by:
create
in interfaceJobManagerJobMetricGroupFactory
- Parameters:
executionPlan
- for which to create a newJobManagerJobMetricGroup
.- Returns:
JobManagerJobMetricGroup
-
-