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 Object
implements OpenLineage.BaseEvent

model class for DatasetEvent

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method	Description
Map<String,Object>	getAdditionalProperties()
OpenLineage.StaticDataset	getDataset()
ZonedDateTime	getEventTime()
URI	getProducer()
URI	getSchemaURL()

Methods inherited from class java.lang.Object

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

Constructor Details

DatasetEvent

public DatasetEvent(ZonedDateTime eventTime,
 URI producer,
 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 Details

getEventTime

public ZonedDateTime getEventTime()

Specified by:

getEventTime in interface OpenLineage.BaseEvent

Returns:

the time the event occurred at

getProducer

public 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 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 Map<String,Object> getAdditionalProperties()

Specified by:

getAdditionalProperties in interface OpenLineage.BaseEvent

Returns:

additional properties