Class OpenTelemetryContextPropagator

java.lang.Object
org.apache.beam.sdk.values.OpenTelemetryContextPropagator

@Internal public class OpenTelemetryContextPropagator extends Object
  • Constructor Details

    • OpenTelemetryContextPropagator

      public OpenTelemetryContextPropagator()
  • Method Details

    • set

      public static void set(Context from, org.apache.beam.model.fnexecution.v1.BeamFnApi.Elements.ElementMetadata.Builder builder)
    • read

      public static Context read(org.apache.beam.model.fnexecution.v1.BeamFnApi.Elements.ElementMetadata from)