org.apache.hadoop.metrics2.sink

クラス StatsDSink

java.lang.Object

org.apache.hadoop.metrics2.sink.StatsDSink

すべての実装されたインタフェース:

Closeable, AutoCloseable, MetricsPlugin, MetricsSink

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public class StatsDSink
extends Object
implements MetricsSink, Closeable

A metrics sink that writes metrics to a StatsD daemon. This sink will produce metrics of the form '[hostname].servicename.context.name.metricname:value|type' where hostname is optional. This is useful when sending to a daemon that is running on the localhost and will add the hostname to the metric (such as the CollectD StatsD plugin).
To configure this plugin, you will need to add the following entries to your hadoop-metrics2.properties file:

 *.sink.statsd.class=org.apache.hadoop.metrics2.sink.StatsDSink
 [prefix].sink.statsd.server.host=
 [prefix].sink.statsd.server.port=
 [prefix].sink.statsd.skip.hostname=true|false (optional)
 [prefix].sink.statsd.service.name=NameNode (name you want for service)
 

コンストラクタのサマリー

コンストラクタ

コンストラクタと説明
StatsDSink()

メソッドのサマリー

修飾子とタイプ	メソッドと説明
void	close()
void	flush() Flush any buffered metrics
void	init(org.apache.commons.configuration.SubsetConfiguration conf) Initialize the plugin
void	putMetrics(MetricsRecord record) Put a metrics record in the sink
void	writeMetric(String line)

クラスから継承されたメソッド java.lang.Object

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

コンストラクタの詳細

StatsDSink

public StatsDSink()

メソッドの詳細

init

public void init(org.apache.commons.configuration.SubsetConfiguration conf)

インタフェースからコピーされた説明: MetricsPlugin

Initialize the plugin

定義:

init インタフェース内 MetricsPlugin

パラメータ:

conf - the configuration object for the plugin

putMetrics

public void putMetrics(MetricsRecord record)

インタフェースからコピーされた説明: MetricsSink

Put a metrics record in the sink

定義:

putMetrics インタフェース内 MetricsSink

パラメータ:

record - the record to put

writeMetric

public void writeMetric(String line)

flush

public void flush()

インタフェースからコピーされた説明: MetricsSink

Flush any buffered metrics

定義:

flush インタフェース内 MetricsSink

close

public void close()
           throws IOException

定義:

close インタフェース内 Closeable

定義:

close インタフェース内 AutoCloseable

例外:

IOException