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 and Description
static String	METRIC_GROUP_INPUT
static String	METRIC_GROUP_OUTPUT

Method Summary

Modifier and Type	Method and Description
static MetricGroup	createShuffleIOOwnerMetricGroup(MetricGroup parentGroup)
static void	registerDebloatingTaskMetrics(SingleInputGate[] inputGates, MetricGroup taskGroup)
static void	registerInputMetrics(boolean isDetailedMetrics, MetricGroup inputGroup, SingleInputGate[] inputGates)
static void	registerLegacyNetworkMetrics(boolean isDetailedMetrics, MetricGroup metricGroup, ResultPartitionWriter[] producedPartitions, InputGate[] inputGates) Deprecated. should be removed in future
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)

registerLegacyNetworkMetrics

@Deprecated
public static void registerLegacyNetworkMetrics(boolean isDetailedMetrics,
                                                            MetricGroup metricGroup,
                                                            ResultPartitionWriter[] producedPartitions,
                                                            InputGate[] inputGates)

Deprecated. should be removed in future

Registers legacy network metric groups before shuffle service refactoring.

Registers legacy metric groups if shuffle service implementation is original default one.

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)