Package io.openlineage.client.transports

Class TransformTransport

java.lang.Object

io.openlineage.client.transports.Transport

io.openlineage.client.transports.TransformTransport

All Implemented Interfaces:

AutoCloseable

public class TransformTransport
extends Transport

Constructor Summary

Constructors

Constructor	Description
TransformTransport(@NonNull TransformConfig config)
TransformTransport(@NonNull TransformConfig config, Transport transport)

Method Summary

Modifier and Type	Method	Description
void	close()
void	emit(@NonNull OpenLineage.DatasetEvent datasetEvent)
void	emit(@NonNull OpenLineage.JobEvent jobEvent)
void	emit(OpenLineage.RunEvent runEvent)
EventTransformer	getTransformer()
Transport	getTransport()

Methods inherited from class java.lang.Object

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

Constructor Details

TransformTransport

public TransformTransport(@NonNull
 @NonNull TransformConfig config)

TransformTransport

public TransformTransport(@NonNull
 @NonNull TransformConfig config,
 Transport transport)

Method Details

emit

public void emit(@NonNull
 OpenLineage.RunEvent runEvent)

Specified by:

emit in class Transport

emit

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

Specified by:

emit in class Transport

emit

public void emit(@NonNull
 @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

getTransport

public Transport getTransport()

getTransformer

public EventTransformer getTransformer()