Package io.openlineage.server

Class OpenLineage.DatasetEvent

java.lang.Object

io.openlineage.server.OpenLineage.DatasetEvent

All Implemented Interfaces:

OpenLineage.BaseEvent

Enclosing class:

OpenLineage

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

Constructor Summary

Constructors

Constructor	Description
DatasetEvent(java.time.ZonedDateTime eventTime, java.net.URI producer, java.net.URI schemaURL, OpenLineage.StaticDataset dataset)

Method Summary

Modifier and Type	Method	Description
java.util.Map<java.lang.String,java.lang.Object>	getAdditionalProperties()
OpenLineage.StaticDataset	getDataset()
java.time.ZonedDateTime	getEventTime()
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

DatasetEvent

public DatasetEvent(java.time.ZonedDateTime eventTime,
                    java.net.URI producer,
                    java.net.URI schemaURL,
                    OpenLineage.StaticDataset dataset)

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

dataset - the dataset

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

getDataset

public OpenLineage.StaticDataset getDataset()

getAdditionalProperties

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

Specified by:

getAdditionalProperties in interface OpenLineage.BaseEvent

Returns:

additional properties