Class Slf4jReporter

  • All Implemented Interfaces:
    org.apache.flink.metrics.CharacterFilter, org.apache.flink.metrics.Reporter, org.apache.flink.metrics.reporter.MetricReporter, org.apache.flink.metrics.reporter.Scheduled

    public class Slf4jReporter
    extends org.apache.flink.metrics.reporter.AbstractReporter
    implements org.apache.flink.metrics.reporter.Scheduled
    MetricReporter that exports Metrics via SLF4J Logger.
    • Constructor Detail

      • Slf4jReporter

        public Slf4jReporter()
    • Method Detail

      • open

        public void open​(org.apache.flink.metrics.MetricConfig metricConfig)
        Specified by:
        open in interface org.apache.flink.metrics.Reporter
      • close

        public void close()
        Specified by:
        close in interface org.apache.flink.metrics.Reporter
      • report

        public void report()
        Specified by:
        report in interface org.apache.flink.metrics.reporter.Scheduled
      • filterCharacters

        public String filterCharacters​(String input)
        Specified by:
        filterCharacters in interface org.apache.flink.metrics.CharacterFilter