Package io.openlineage.client

Class OpenLineage.RunEvent

java.lang.Object
io.openlineage.client.OpenLineage.RunEvent
Enclosing class:
OpenLineage
public static final class OpenLineage.RunEvent
extends java.lang.Object

  • Method Details

    • getEventType

      public java.lang.String getEventType()
      Returns:
      the current transition of the run state. It is required to issue 1 START event and 1 of [ COMPLETE, ABORT, FAIL ] event per run. Additional events with OTHER eventType can be added to the same run. For example to send additional metadata after the run is complete

    • getEventTime

      public java.time.ZonedDateTime getEventTime()
      Returns:
      the time the event occured at

    • getRun

      public OpenLineage.Run getRun()

    • getJob

      public OpenLineage.Job getJob()

    • getInputs

      public java.util.List<OpenLineage.InputDataset> getInputs()
      Returns:
      The set of **input** datasets.

    • getOutputs

      public java.util.List<OpenLineage.OutputDataset> getOutputs()
      Returns:
      The set of **output** datasets.

    • getProducer

      public java.net.URI getProducer()
      Returns:
      URI identifying the producer of this metadata. For example this could be a git url with a given tag or sha

    • getSchemaURL

      public java.net.URI getSchemaURL()
      Returns:
      The JSON Pointer (https://tools.ietf.org/html/rfc6901) URL to the corresponding version of the schema definition for this RunEvent