org.apache.flink.runtime.metrics.util

Class MetricUtils

java.lang.Object

org.apache.flink.runtime.metrics.util.MetricUtils

public class MetricUtils
extends Object

Utility class to register pre-defined metric sets.

Method Summary

Modifier and Type	Method and Description
static JobManagerMetricGroup	instantiateJobManagerMetricGroup(MetricRegistry metricRegistry, String hostname)
static ProcessMetricGroup	instantiateProcessMetricGroup(MetricRegistry metricRegistry, String hostname, Optional<Time> systemResourceProbeInterval)
static void	instantiateStatusMetrics(MetricGroup metricGroup)
static Tuple2<TaskManagerMetricGroup,MetricGroup>	instantiateTaskManagerMetricGroup(MetricRegistry metricRegistry, String hostName, ResourceID resourceID, Optional<Time> systemResourceProbeInterval)
static RpcService	startLocalMetricsRpcService(Configuration configuration)
static RpcService	startRemoteMetricsRpcService(Configuration configuration, String hostname)

Methods inherited from class java.lang.Object

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

Method Detail

instantiateProcessMetricGroup

public static ProcessMetricGroup instantiateProcessMetricGroup(MetricRegistry metricRegistry,
                                                               String hostname,
                                                               Optional<Time> systemResourceProbeInterval)

instantiateJobManagerMetricGroup

public static JobManagerMetricGroup instantiateJobManagerMetricGroup(MetricRegistry metricRegistry,
                                                                     String hostname)

instantiateTaskManagerMetricGroup

public static Tuple2<TaskManagerMetricGroup,MetricGroup> instantiateTaskManagerMetricGroup(MetricRegistry metricRegistry,
                                                                                           String hostName,
                                                                                           ResourceID resourceID,
                                                                                           Optional<Time> systemResourceProbeInterval)

instantiateStatusMetrics

public static void instantiateStatusMetrics(MetricGroup metricGroup)

startRemoteMetricsRpcService

public static RpcService startRemoteMetricsRpcService(Configuration configuration,
                                                      String hostname)
                                               throws Exception

Throws:

Exception

startLocalMetricsRpcService

public static RpcService startLocalMetricsRpcService(Configuration configuration)
                                              throws Exception

Throws:

Exception