Uses of Interface
org.apache.flink.metrics.groups.OperatorMetricGroup

Packages that use OperatorMetricGroup

Package	Description
org.apache.flink.api.common.functions
org.apache.flink.api.common.functions.util
org.apache.flink.metrics.groups
org.apache.flink.runtime.iterative.task
org.apache.flink.runtime.metrics.groups
org.apache.flink.runtime.operators
org.apache.flink.runtime.operators.util
org.apache.flink.state.api.output.operators
org.apache.flink.state.api.runtime
org.apache.flink.streaming.api.operators

Uses of OperatorMetricGroup in org.apache.flink.api.common.functions

Methods in org.apache.flink.api.common.functions that return OperatorMetricGroup

Modifier and Type	Method and Description
OperatorMetricGroup	RuntimeContext.getMetricGroup() Returns the metric group for this parallel subtask.

Uses of OperatorMetricGroup in org.apache.flink.api.common.functions.util

Methods in org.apache.flink.api.common.functions.util that return OperatorMetricGroup

Modifier and Type	Method and Description
OperatorMetricGroup	AbstractRuntimeUDFContext.getMetricGroup()

Constructors in org.apache.flink.api.common.functions.util with parameters of type OperatorMetricGroup

Constructor and Description
AbstractRuntimeUDFContext(TaskInfo taskInfo, UserCodeClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Accumulator<?,?>> accumulators, Map<String,Future<Path>> cpTasks, OperatorMetricGroup metrics)
RuntimeUDFContext(TaskInfo taskInfo, ClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Future<Path>> cpTasks, Map<String,Accumulator<?,?>> accumulators, OperatorMetricGroup metrics)
RuntimeUDFContext(TaskInfo taskInfo, ClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Future<Path>> cpTasks, Map<String,Accumulator<?,?>> accumulators, OperatorMetricGroup metrics, JobID jobID)

Uses of OperatorMetricGroup in org.apache.flink.metrics.groups

Subinterfaces of OperatorMetricGroup in org.apache.flink.metrics.groups

Modifier and Type	Interface and Description
interface	SinkWriterMetricGroup Pre-defined metrics for sinks.
interface	SourceReaderMetricGroup Pre-defined metrics for SourceReader.

Methods in org.apache.flink.metrics.groups that return OperatorMetricGroup

Modifier and Type	Method and Description
static OperatorMetricGroup	UnregisteredMetricsGroup.createOperatorMetricGroup()

Uses of OperatorMetricGroup in org.apache.flink.runtime.iterative.task

Methods in org.apache.flink.runtime.iterative.task with parameters of type OperatorMetricGroup

Modifier and Type	Method and Description
DistributedRuntimeUDFContext	AbstractIterativeTask.createRuntimeContext(OperatorMetricGroup metrics)

Uses of OperatorMetricGroup in org.apache.flink.runtime.metrics.groups

Classes in org.apache.flink.runtime.metrics.groups that implement OperatorMetricGroup

Modifier and Type	Class and Description
class	InternalOperatorMetricGroup Special MetricGroup representing an Operator.
class	InternalSinkWriterMetricGroup Special MetricGroup representing an Operator.
class	InternalSourceReaderMetricGroup Special MetricGroup representing an Operator.
static class	UnregisteredMetricGroups.UnregisteredOperatorMetricGroup A safe drop-in replacement for InternalOperatorMetricGroups.

Methods in org.apache.flink.runtime.metrics.groups with parameters of type OperatorMetricGroup

Modifier and Type	Method and Description
static InternalSinkWriterMetricGroup	InternalSinkWriterMetricGroup.wrap(OperatorMetricGroup operatorMetricGroup)
static InternalSourceReaderMetricGroup	InternalSourceReaderMetricGroup.wrap(OperatorMetricGroup operatorMetricGroup)

Uses of OperatorMetricGroup in org.apache.flink.runtime.operators

Methods in org.apache.flink.runtime.operators that return OperatorMetricGroup

Modifier and Type	Method and Description
OperatorMetricGroup	BatchTask.getMetricGroup()
OperatorMetricGroup	TaskContext.getMetricGroup()

Methods in org.apache.flink.runtime.operators with parameters of type OperatorMetricGroup

Modifier and Type	Method and Description
DistributedRuntimeUDFContext	BatchTask.createRuntimeContext(OperatorMetricGroup metrics)

Uses of OperatorMetricGroup in org.apache.flink.runtime.operators.util

Constructors in org.apache.flink.runtime.operators.util with parameters of type OperatorMetricGroup

Constructor and Description
DistributedRuntimeUDFContext(TaskInfo taskInfo, UserCodeClassLoader userCodeClassLoader, ExecutionConfig executionConfig, Map<String,Future<Path>> cpTasks, Map<String,Accumulator<?,?>> accumulators, OperatorMetricGroup metrics, ExternalResourceInfoProvider externalResourceInfoProvider, JobID jobID)

Uses of OperatorMetricGroup in org.apache.flink.state.api.output.operators

Methods in org.apache.flink.state.api.output.operators that return OperatorMetricGroup

Modifier and Type	Method and Description
OperatorMetricGroup	StateBootstrapWrapperOperator.getMetricGroup()

Uses of OperatorMetricGroup in org.apache.flink.state.api.runtime

Methods in org.apache.flink.state.api.runtime that return OperatorMetricGroup

Modifier and Type	Method and Description
OperatorMetricGroup	SavepointRuntimeContext.getMetricGroup()

Uses of OperatorMetricGroup in org.apache.flink.streaming.api.operators

Methods in org.apache.flink.streaming.api.operators that return OperatorMetricGroup

Modifier and Type	Method and Description
OperatorMetricGroup	AbstractStreamOperatorV2.getMetricGroup()
OperatorMetricGroup	AbstractStreamOperator.getMetricGroup()
OperatorMetricGroup	StreamOperator.getMetricGroup()

Methods in org.apache.flink.streaming.api.operators with parameters of type OperatorMetricGroup

Modifier and Type	Method and Description
protected Output<StreamRecord<OUT>>	AbstractStreamOperator.registerCounterOnOutput(Output<StreamRecord<OUT>> output, OperatorMetricGroup operatorMetricGroup)

Constructors in org.apache.flink.streaming.api.operators with parameters of type OperatorMetricGroup

Constructor and Description
StreamingRuntimeContext(Environment env, Map<String,Accumulator<?,?>> accumulators, OperatorMetricGroup operatorMetricGroup, OperatorID operatorID, ProcessingTimeService processingTimeService, KeyedStateStore keyedStateStore, ExternalResourceInfoProvider externalResourceInfoProvider)