Package io.openlineage.client.transports

Class FileTransport

java.lang.Object

io.openlineage.client.transports.Transport

io.openlineage.client.transports.FileTransport

public class FileTransport
extends Transport

Appends Openlineage events to a file specified. Events are separated by a newline character, while all the existing newline characters within event json are removed. FileTransport was introduced for the purpose of integration tests.

Constructor Summary

Constructors

Constructor	Description
FileTransport(@NonNull FileConfig fileConfig)

Method Summary

Modifier and Type	Method	Description
void	emit(OpenLineage.DatasetEvent datasetEvent)
void	emit(OpenLineage.JobEvent jobEvent)
void	emit(OpenLineage.RunEvent runEvent)

Methods inherited from class java.lang.Object

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

Constructor Details

FileTransport

public FileTransport(@NonNull
 @NonNull FileConfig fileConfig)

Method Details

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