Class OpenTelemetryTraceReporter

  • All Implemented Interfaces:
    org.apache.flink.metrics.Reporter, org.apache.flink.traces.reporter.TraceReporter

    public class OpenTelemetryTraceReporter
    extends OpenTelemetryReporterBase
    implements org.apache.flink.traces.reporter.TraceReporter
    A Flink TraceReporter which is made to export spans using Open Telemetry's SpanExporter.
    • Constructor Detail

      • OpenTelemetryTraceReporter

        public OpenTelemetryTraceReporter()
    • 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
      • notifyOfAddedSpan

        public void notifyOfAddedSpan​(org.apache.flink.traces.Span span)
        Specified by:
        notifyOfAddedSpan in interface org.apache.flink.traces.reporter.TraceReporter