Package org.apache.flink.traces.otel
Class OpenTelemetryTraceReporter
- java.lang.Object
-
- org.apache.flink.metrics.otel.OpenTelemetryReporterBase
-
- org.apache.flink.traces.otel.OpenTelemetryTraceReporter
-
- All Implemented Interfaces:
org.apache.flink.traces.reporter.TraceReporter
public class OpenTelemetryTraceReporter extends OpenTelemetryReporterBase implements org.apache.flink.traces.reporter.TraceReporter
A FlinkTraceReporterwhich is made to export spans using Open Telemetry'sSpanExporter.
-
-
Field Summary
-
Fields inherited from class org.apache.flink.metrics.otel.OpenTelemetryReporterBase
exporter, resource
-
-
Constructor Summary
Constructors Constructor Description OpenTelemetryTraceReporter()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidclose()voidnotifyOfAddedSpan(org.apache.flink.traces.Span span)voidopen(org.apache.flink.metrics.MetricConfig metricConfig)
-
-
-
Method Detail
-
open
public void open(org.apache.flink.metrics.MetricConfig metricConfig)
- Specified by:
openin interfaceorg.apache.flink.traces.reporter.TraceReporter- Overrides:
openin classOpenTelemetryReporterBase
-
close
public void close()
- Specified by:
closein interfaceorg.apache.flink.traces.reporter.TraceReporter
-
notifyOfAddedSpan
public void notifyOfAddedSpan(org.apache.flink.traces.Span span)
- Specified by:
notifyOfAddedSpanin interfaceorg.apache.flink.traces.reporter.TraceReporter
-
-