Package org.apache.flink.runtime.io.network.metrics

Class NettyShuffleMetricFactory

java.lang.Object

org.apache.flink.runtime.io.network.metrics.NettyShuffleMetricFactory

public class NettyShuffleMetricFactory
extends Object

Factory for netty shuffle service metrics.

Field Summary

Fields

Modifier and Type	Field	Description
static String	METRIC_GROUP_INPUT
static String	METRIC_GROUP_OUTPUT

Method Summary

Modifier and Type	Method	Description
static MetricGroup	createShuffleIOOwnerMetricGroup(MetricGroup parentGroup)
static void	registerDebloatingTaskMetrics(SingleInputGate[] inputGates, MetricGroup taskGroup)
static void	registerInputMetrics(boolean isDetailedMetrics, MetricGroup inputGroup, SingleInputGate[] inputGates)
static void	registerOutputMetrics(boolean isDetailedMetrics, MetricGroup outputGroup, ResultPartition[] resultPartitions)
static void	registerShuffleMetrics(MetricGroup metricGroup, NetworkBufferPool networkBufferPool)

Methods inherited from class java.lang.Object

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

Field Detail

METRIC_GROUP_OUTPUT

public static final String METRIC_GROUP_OUTPUT

See Also:

Constant Field Values

METRIC_GROUP_INPUT

public static final String METRIC_GROUP_INPUT

See Also:

Constant Field Values

Method Detail

registerShuffleMetrics

public static void registerShuffleMetrics(MetricGroup metricGroup,
                                          NetworkBufferPool networkBufferPool)

createShuffleIOOwnerMetricGroup

public static MetricGroup createShuffleIOOwnerMetricGroup(MetricGroup parentGroup)

registerOutputMetrics

public static void registerOutputMetrics(boolean isDetailedMetrics,
                                         MetricGroup outputGroup,
                                         ResultPartition[] resultPartitions)

registerInputMetrics

public static void registerInputMetrics(boolean isDetailedMetrics,
                                        MetricGroup inputGroup,
                                        SingleInputGate[] inputGates)

registerDebloatingTaskMetrics

public static void registerDebloatingTaskMetrics(SingleInputGate[] inputGates,
                                                 MetricGroup taskGroup)