Class OpenTelemetryEventReporter

  • All Implemented Interfaces:
    org.apache.flink.events.reporter.EventReporter, org.apache.flink.metrics.Reporter

    public class OpenTelemetryEventReporter
    extends OpenTelemetryReporterBase
    implements org.apache.flink.events.reporter.EventReporter
    A Flink EventReporter which is made to export log records/events using Open Telemetry's LogRecordExporter.
    • Constructor Detail

      • OpenTelemetryEventReporter

        public OpenTelemetryEventReporter()
    • Method Detail

      • open

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

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

        public void notifyOfAddedEvent​(org.apache.flink.events.Event event)
        Specified by:
        notifyOfAddedEvent in interface org.apache.flink.events.reporter.EventReporter