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
All Methods Instance Methods Concrete Methods Modifier and Type Method Description void
emit(OpenLineage.DatasetEvent datasetEvent)
void
emit(OpenLineage.JobEvent jobEvent)
void
emit(OpenLineage.RunEvent runEvent)
-
-
-
Constructor Detail
-
FileTransport
public FileTransport(@NonNull @NonNull FileConfig fileConfig)
-
-
Method Detail
-
emit
public void emit(@NonNull OpenLineage.RunEvent runEvent)
-
emit
public void emit(@NonNull OpenLineage.DatasetEvent datasetEvent)
-
emit
public void emit(@NonNull OpenLineage.JobEvent jobEvent)
-
-