org.apache.beam.runners.flink.metrics

Class FileReporter

java.lang.Object

org.apache.flink.metrics.reporter.AbstractReporter

org.apache.beam.runners.flink.metrics.FileReporter

All Implemented Interfaces:

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

public class FileReporter
extends org.apache.flink.metrics.reporter.AbstractReporter

Flink metrics reporter for writing metrics to a file specified via the "metrics.reporter.file.path" config key (assuming an alias of "file" for this reporter in the "metrics.reporters" setting).

Field Summary

Fields inherited from class org.apache.flink.metrics.reporter.AbstractReporter

counters, gauges, histograms, log, meters

Constructor Summary

Constructors

Constructor and Description
FileReporter()

Method Summary

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

Methods inherited from class org.apache.flink.metrics.reporter.AbstractReporter

notifyOfAddedMetric

Methods inherited from class java.lang.Object

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

Constructor Detail

FileReporter

public FileReporter()

Method Detail

filterCharacters

public java.lang.String filterCharacters(java.lang.String input)

open

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

notifyOfRemovedMetric

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

Specified by:

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

Overrides:

notifyOfRemovedMetric in class org.apache.flink.metrics.reporter.AbstractReporter

close

public void close()