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 Summary
Modifier and Type Method Description java.time.ZonedDateTime
getEventTime()
java.lang.String
getEventType()
java.util.List<OpenLineage.InputDataset>
getInputs()
OpenLineage.Job
getJob()
java.util.List<OpenLineage.OutputDataset>
getOutputs()
java.net.URI
getProducer()
OpenLineage.Run
getRun()
java.net.URI
getSchemaURL()
-
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
-
getJob
-
getInputs
- Returns:
- The set of **input** datasets.
-
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
-