Package org.apache.storm.metricstore
Class Metric
java.lang.Object
org.apache.storm.metricstore.Metric
- All Implemented Interfaces:
Comparable<Metric>
Class containing metric values and all identifying fields to be stored in a MetricStore.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoidaddValue(double value) Adds an additional value to the metric.intbooleanCheck if a Metric matches another object.longgetCount()doublegetMax()doublegetMin()getPort()doublegetSum()longdoublegetValue()voidsetAggLevel(AggLevel aggLevel) Set the aggLevel.voidsetCount(long count) voidsetMax(double max) voidsetMin(double min) voidsetSum(double sum) voidsetTimestamp(long timestamp) voidsetTopologyId(String topologyId) voidsetValue(double value) Initialize the metric value.toString()
-
Constructor Details
-
Metric
public Metric(String name, Long timestamp, String topologyId, double value, String componentId, String executorId, String hostname, String streamId, int port, AggLevel aggLevel) throws MetricException Metric constructor.- Throws:
MetricException
-
Metric
A Metric constructor with the same settings cloned from another.
-
-
Method Details
-
equals
Check if a Metric matches another object. -
getAggLevel
-
setAggLevel
Set the aggLevel.- Throws:
MetricException
-
addValue
public void addValue(double value) Adds an additional value to the metric. -
getSum
public double getSum() -
setSum
public void setSum(double sum) -
getCount
public long getCount() -
setCount
public void setCount(long count) -
getMin
public double getMin() -
setMin
public void setMin(double min) -
getMax
public double getMax() -
setMax
public void setMax(double max) -
getTopologyId
-
setTopologyId
-
getTimestamp
public long getTimestamp() -
setTimestamp
public void setTimestamp(long timestamp) -
getValue
public double getValue() -
setValue
public void setValue(double value) Initialize the metric value. -
getMetricName
-
getComponentId
-
getExecutorId
-
getHostname
-
getStreamId
-
getPort
-
compareTo
- Specified by:
compareToin interfaceComparable<Metric>
-
toString
-