org.apache.nifi.reporting.ambari.metrics

Class MetricsService

java.lang.Object

org.apache.nifi.reporting.ambari.metrics.MetricsService

public class MetricsService
extends java.lang.Object

A service used to produce key/value metrics based on a given input.

Constructor Summary

Constructors

Constructor and Description
MetricsService()

Method Summary

Modifier and Type	Method and Description
protected long	calculateProcessingNanos(ProcessGroupStatus status)
java.util.Map<java.lang.String,java.lang.String>	getMetrics(ProcessGroupStatus status, boolean appendPgId) Generates a Map of metrics for a ProcessGroupStatus instance.
java.util.Map<java.lang.String,java.lang.String>	getMetrics(com.yammer.metrics.core.VirtualMachineMetrics virtualMachineMetrics) Generates a Map of metrics for VirtualMachineMetrics.

Methods inherited from class java.lang.Object

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

Constructor Detail

MetricsService

public MetricsService()

Method Detail

getMetrics

public java.util.Map<java.lang.String,java.lang.String> getMetrics(ProcessGroupStatus status,
                                                                   boolean appendPgId)

Generates a Map of metrics for a ProcessGroupStatus instance.

Parameters:

status - a ProcessGroupStatus to get metrics from

appendPgId - if true, the process group ID will be appended at the end of the metric name

Returns:

a map of metrics for the given status

getMetrics

public java.util.Map<java.lang.String,java.lang.String> getMetrics(com.yammer.metrics.core.VirtualMachineMetrics virtualMachineMetrics)

Generates a Map of metrics for VirtualMachineMetrics.

Parameters:

virtualMachineMetrics - a VirtualMachineMetrics instance to get metrics from

Returns:

a map of metrics from the given VirtualMachineStatus

calculateProcessingNanos

protected long calculateProcessingNanos(ProcessGroupStatus status)