Package io.openlineage.server

Class OpenLineage.JobEvent

java.lang.Object

io.openlineage.server.OpenLineage.JobEvent

All Implemented Interfaces:

OpenLineage.BaseEvent

Enclosing class:

OpenLineage

public static final class OpenLineage.JobEvent
extends java.lang.Object
implements OpenLineage.BaseEvent

Constructor Summary

Constructors

Constructor	Description
JobEvent(java.time.ZonedDateTime eventTime, java.net.URI producer, java.net.URI schemaURL, OpenLineage.Job job, java.util.List<OpenLineage.InputDataset> inputs, java.util.List<OpenLineage.OutputDataset> outputs)

Method Summary

Modifier and Type	Method	Description
java.util.Map<java.lang.String,java.lang.Object>	getAdditionalProperties()
java.time.ZonedDateTime	getEventTime()
java.util.List<OpenLineage.InputDataset>	getInputs()
OpenLineage.Job	getJob()
java.util.List<OpenLineage.OutputDataset>	getOutputs()
java.net.URI	getProducer()
java.net.URI	getSchemaURL()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

JobEvent

public JobEvent(java.time.ZonedDateTime eventTime,
                java.net.URI producer,
                java.net.URI schemaURL,
                OpenLineage.Job job,
                java.util.List<OpenLineage.InputDataset> inputs,
                java.util.List<OpenLineage.OutputDataset> outputs)

Parameters:

eventTime - the time the event occurred at

producer - URI identifying the producer of this metadata. For example this could be a git url with a given tag or sha

schemaURL - The JSON Pointer (https://tools.ietf.org/html/rfc6901) URL to the corresponding version of the schema definition for this RunEvent

job - the job

inputs - The set of **input** datasets.

outputs - The set of **output** datasets.

Method Detail

getEventTime

public java.time.ZonedDateTime getEventTime()

Specified by:

getEventTime in interface OpenLineage.BaseEvent

Returns:

the time the event occurred at

getProducer

public java.net.URI getProducer()

Specified by:

getProducer in interface OpenLineage.BaseEvent

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()

Specified by:

getSchemaURL in interface OpenLineage.BaseEvent

Returns:

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

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.

getAdditionalProperties

public java.util.Map<java.lang.String,java.lang.Object> getAdditionalProperties()

Specified by:

getAdditionalProperties in interface OpenLineage.BaseEvent

Returns:

additional properties