Package io.openlineage.client.transports

Class Transport

java.lang.Object

io.openlineage.client.transports.Transport

All Implemented Interfaces:

AutoCloseable

Direct Known Subclasses:

CompositeTransport, ConsoleTransport, FileTransport, HttpTransport, KafkaTransport, NoopTransport, TransformTransport

public abstract class Transport
extends Object
implements AutoCloseable

Constructor Summary

Constructors

Constructor	Description
Transport()

Method Summary

Modifier and Type	Method	Description
void	close()
abstract void	emit(OpenLineage.DatasetEvent datasetEvent)
abstract void	emit(OpenLineage.JobEvent jobEvent)
abstract void	emit(OpenLineage.RunEvent runEvent)
void	emit(OpenLineage.RunEvent runEvent, @NonNull Duration timeout)	Emit the given run event with a bounded wait when supported by the transport.

Methods inherited from class java.lang.Object

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

Constructor Details

Transport

public Transport()

Method Details

emit

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

emit

public abstract void emit(@NonNull
 OpenLineage.DatasetEvent datasetEvent)

emit

public abstract void emit(@NonNull
 OpenLineage.JobEvent jobEvent)

emit

public void emit(@NonNull
 OpenLineage.RunEvent runEvent,
 @NonNull
 @NonNull Duration timeout)

Emit the given run event with a bounded wait when supported by the transport.

The default implementation keeps regular emit behavior for transports that do not support delivery acknowledgement.

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception