Package io.openlineage.client.transports

Class Transport

java.lang.Object

io.openlineage.client.transports.Transport

Direct Known Subclasses:

ConsoleTransport, FileTransport, HttpTransport, KafkaTransport, KinesisTransport, NoopTransport

public abstract class Transport
extends java.lang.Object

Constructor Summary

Constructors

Constructor	Description
Transport()

Method Summary

Modifier and Type	Method	Description
void	emit(OpenLineage.DatasetEvent datasetEvent)
void	emit(OpenLineage.JobEvent jobEvent)
abstract void	emit(OpenLineage.RunEvent runEvent)
void	emit(java.lang.String eventAsJson)	Deprecated. Since version 1.13.0.

Methods inherited from class java.lang.Object

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

Constructor Detail

Transport

public Transport()

Method Detail

emit

public abstract void emit(@NonNull
                          OpenLineage.RunEvent runEvent)

emit

public void emit(@NonNull
                 OpenLineage.DatasetEvent datasetEvent)

emit

public void emit(@NonNull
                 OpenLineage.JobEvent jobEvent)

emit

@Deprecated
public void emit(java.lang.String eventAsJson)

Deprecated.

Since version 1.13.0.

Will be removed in version 1.16.0.

Please use emit(OpenLineage.DatasetEvent) or emit(OpenLineage.JobEvent) instead

Parameters:

eventAsJson - string json event