org.apache.hadoop.metrics2.sink.ganglia
Class GangliaSink30
java.lang.Object
org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink
org.apache.hadoop.metrics2.sink.ganglia.GangliaSink30
- All Implemented Interfaces:
- MetricsPlugin, MetricsSink
- Direct Known Subclasses:
- GangliaSink31
public class GangliaSink30
- extends AbstractGangliaSink
This code supports Ganglia 3.0
Fields inherited from class org.apache.hadoop.metrics2.sink.ganglia.AbstractGangliaSink |
BUFFER_SIZE, DEFAULT_DMAX, DEFAULT_PORT, DEFAULT_SLOPE, DEFAULT_TMAX, DEFAULT_UNITS, EQUAL, gangliaMetricVisitor, SERVERS_PROPERTY, SUPPORT_SPARSE_METRICS_DEFAULT, SUPPORT_SPARSE_METRICS_PROPERTY |
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
LOG
public final org.apache.commons.logging.Log LOG
metricsCache
protected MetricsCache metricsCache
GangliaSink30
public GangliaSink30()
putMetrics
public void putMetrics(MetricsRecord record)
- Description copied from interface:
MetricsSink
- Put a metrics record in the sink
- Parameters:
record
- the record to put
emitMetric
protected void emitMetric(String groupName,
String name,
String type,
String value,
org.apache.hadoop.metrics2.sink.ganglia.GangliaConf gConf,
AbstractGangliaSink.GangliaSlope gSlope)
throws IOException
- The method sends metrics to Ganglia servers. The method has been taken from
org.apache.hadoop.metrics.ganglia.GangliaContext30 with minimal changes in
order to keep it in sync.
- Parameters:
groupName
- The group name of the metricname
- The metric nametype
- The type of the metricvalue
- The value of the metricgConf
- The GangliaConf for this metricgSlope
- The slope for this metric
- Throws:
IOException
Copyright © 2009 The Apache Software Foundation