Package 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

    Fields inherited from interface org.apache.flink.metrics.CharacterFilter

    NO_OP_FILTER

  • Constructor Summary

    Constructors
    Constructor
    Description
    FileReporter()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    String
    filterCharacters(String input)
     
    void
    notifyOfRemovedMetric(org.apache.flink.metrics.Metric metric, 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 Details

    • FileReporter

      public FileReporter()

  • Method Details

    • filterCharacters

      public String filterCharacters(String input)

    • open

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

    • 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
      Overrides:
      notifyOfRemovedMetric in class org.apache.flink.metrics.reporter.AbstractReporter

    • close

      public void close()