Package org.apache.flink.metrics.influxdb

Class InfluxdbReporter

java.lang.Object

org.apache.flink.metrics.influxdb.InfluxdbReporter

All Implemented Interfaces:

org.apache.flink.metrics.reporter.MetricReporter, org.apache.flink.metrics.reporter.Scheduled

public class InfluxdbReporter
extends Object
implements org.apache.flink.metrics.reporter.Scheduled

MetricReporter that exports Metrics via InfluxDB.

Field Summary

Fields

Modifier and Type	Field	Description
protected Map<org.apache.flink.metrics.Counter,MetricInfo>	counters
protected Map<org.apache.flink.metrics.Gauge<?>,MetricInfo>	gauges
protected Map<org.apache.flink.metrics.Histogram,MetricInfo>	histograms
protected org.slf4j.Logger	log
protected Map<org.apache.flink.metrics.Meter,MetricInfo>	meters
protected org.apache.flink.metrics.influxdb.MetricInfoProvider<MetricInfo>	metricInfoProvider

Constructor Summary

Constructors

Constructor	Description
InfluxdbReporter()

Method Summary

Modifier and Type	Method	Description
void	close()
void	notifyOfAddedMetric(org.apache.flink.metrics.Metric metric, String metricName, org.apache.flink.metrics.MetricGroup group)
void	notifyOfRemovedMetric(org.apache.flink.metrics.Metric metric, String metricName, org.apache.flink.metrics.MetricGroup group)
void	open(org.apache.flink.metrics.MetricConfig config)
void	report()

Methods inherited from class java.lang.Object

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

Field Detail

log

protected final org.slf4j.Logger log

gauges

protected final Map<org.apache.flink.metrics.Gauge<?>,MetricInfo> gauges

counters

protected final Map<org.apache.flink.metrics.Counter,MetricInfo> counters

histograms

protected final Map<org.apache.flink.metrics.Histogram,MetricInfo> histograms

meters

protected final Map<org.apache.flink.metrics.Meter,MetricInfo> meters

metricInfoProvider

protected final org.apache.flink.metrics.influxdb.MetricInfoProvider<MetricInfo> metricInfoProvider

Constructor Detail

InfluxdbReporter

public InfluxdbReporter()

Method Detail

open

public void open(org.apache.flink.metrics.MetricConfig config)

Specified by:

open in interface org.apache.flink.metrics.reporter.MetricReporter

close

public void close()

Specified by:

close in interface org.apache.flink.metrics.reporter.MetricReporter

report

public void report()

Specified by:

report in interface org.apache.flink.metrics.reporter.Scheduled

notifyOfAddedMetric

public void notifyOfAddedMetric(org.apache.flink.metrics.Metric metric,
                                String metricName,
                                org.apache.flink.metrics.MetricGroup group)

Specified by:

notifyOfAddedMetric in interface org.apache.flink.metrics.reporter.MetricReporter

notifyOfRemovedMetric

public void notifyOfRemovedMetric(org.apache.flink.metrics.Metric metric,
                                  String metricName,
                                  org.apache.flink.metrics.MetricGroup group)

Specified by:

notifyOfRemovedMetric in interface org.apache.flink.metrics.reporter.MetricReporter