Class OpenLineageClient


  • public final class OpenLineageClient
    extends java.lang.Object
    HTTP client used to emit OpenLineage.RunEvents to HTTP backend.
    • Constructor Detail

      • OpenLineageClient

        public OpenLineageClient()
        Creates a new OpenLineageClient object.
      • OpenLineageClient

        public OpenLineageClient​(@NonNull
                                 @NonNull Transport transport)
      • OpenLineageClient

        public OpenLineageClient​(@NonNull
                                 @NonNull Transport transport,
                                 java.lang.String... disabledFacets)
      • OpenLineageClient

        public OpenLineageClient​(@NonNull
                                 @NonNull Transport transport,
                                 CircuitBreaker circuitBreaker,
                                 java.lang.String... disabledFacets)
    • Method Detail

      • emit

        public void emit​(@NonNull
                         OpenLineage.RunEvent runEvent)
        Emit the given run event to HTTP backend. The method will return successfully after the run event has been emitted, regardless of any exceptions thrown by the HTTP backend.
        Parameters:
        runEvent - The run event to emit.
      • emit

        public void emit​(@NonNull
                         OpenLineage.DatasetEvent datasetEvent)
        Emit the given dataset event to HTTP backend. The method will return successfully after the dataset event has been emitted, regardless of any exceptions thrown by the HTTP backend.
        Parameters:
        datasetEvent - The dataset event to emit.
      • emit

        public void emit​(@NonNull
                         OpenLineage.JobEvent jobEvent)
        Emit the given run event to HTTP backend. The method will return successfully after the run event has been emitted, regardless of any exceptions thrown by the HTTP backend.
        Parameters:
        jobEvent - The job event to emit.