co.cask.coopr.metrics

Class MetricService

java.lang.Object

co.cask.coopr.metrics.MetricService

public class MetricService
extends Object

Util for performing metric operations.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	MetricService.Periodicity

Constructor Summary

Constructors

Constructor and Description
MetricService(ClusterStore clusterStore)

Method Summary

Methods

Modifier and Type	Method and Description
TimeSeries	getNodesUsage(ClusterTaskFilter filter) Calculate statistics of nodes usage for given ClusterTaskFilter.

Methods inherited from class java.lang.Object

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

Constructor Detail

MetricService

public MetricService(ClusterStore clusterStore)

Method Detail

getNodesUsage

public TimeSeries getNodesUsage(ClusterTaskFilter filter)
                         throws IOException

Calculate statistics of nodes usage for given ClusterTaskFilter. The start and end times are inclusive. Loads all tasks with CREATE or DELETE ProvisionerAction. Then, for each node, calculates node live time: finished time of CREATE task to finished time of DELETE task or finished time of CREATE task to current time. If required, then overlays filter's start and end date.

Parameters:

filter - the filter

Returns:

TimeSeries that presents node live time usage

Throws:

IOException