Package io.openlineage.client.transports

Class CompositeTransport

java.lang.Object

io.openlineage.client.transports.Transport

io.openlineage.client.transports.CompositeTransport

All Implemented Interfaces:

AutoCloseable

public class CompositeTransport
extends Transport

Constructor Summary

Constructors

Constructor	Description
CompositeTransport(@NonNull CompositeConfig config)

Method Summary

Modifier and Type	Method	Description
void	close()
void	emit(OpenLineage.DatasetEvent datasetEvent)
void	emit(OpenLineage.JobEvent jobEvent)
void	emit(OpenLineage.RunEvent runEvent)
List<Transport>	getTransports()

Methods inherited from class java.lang.Object

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

Constructor Details

CompositeTransport

public CompositeTransport(@NonNull
 @NonNull CompositeConfig config)

Method Details

getTransports

public List<Transport> getTransports()

emit

public void emit(@NonNull
 OpenLineage.RunEvent runEvent)

Specified by:

emit in class Transport

emit

public void emit(@NonNull
 OpenLineage.DatasetEvent datasetEvent)

Specified by:

emit in class Transport

emit

public void emit(@NonNull
 OpenLineage.JobEvent jobEvent)

Specified by:

emit in class Transport

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Overrides:

close in class Transport

Throws:

Exception