public class MetricUtils extends Object
Modifier and Type | Method and Description |
---|---|
static JobManagerMetricGroup |
instantiateJobManagerMetricGroup(MetricRegistry metricRegistry,
String hostname,
Optional<Time> systemResourceProbeInterval) |
static void |
instantiateStatusMetrics(MetricGroup metricGroup) |
static TaskManagerMetricGroup |
instantiateTaskManagerMetricGroup(MetricRegistry metricRegistry,
TaskManagerLocation taskManagerLocation,
NetworkEnvironment network,
Optional<Time> systemResourceProbeInterval) |
static akka.actor.ActorSystem |
startMetricsActorSystem(Configuration configuration,
String hostname,
org.slf4j.Logger logger) |
public static JobManagerMetricGroup instantiateJobManagerMetricGroup(MetricRegistry metricRegistry, String hostname, Optional<Time> systemResourceProbeInterval)
public static TaskManagerMetricGroup instantiateTaskManagerMetricGroup(MetricRegistry metricRegistry, TaskManagerLocation taskManagerLocation, NetworkEnvironment network, Optional<Time> systemResourceProbeInterval)
public static void instantiateStatusMetrics(MetricGroup metricGroup)
public static akka.actor.ActorSystem startMetricsActorSystem(Configuration configuration, String hostname, org.slf4j.Logger logger) throws Exception
Exception
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.