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 Deprecated Methods Modifier and Type Method Description void
emit(OpenLineage.DatasetEvent datasetEvent)
void
emit(OpenLineage.JobEvent jobEvent)
void
emit(OpenLineage.RunEvent runEvent)
void
emit(java.lang.String eventAsJson)
Deprecated.Since version 1.13.0.
-
-
-
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)
-
emit
@Deprecated public void emit(java.lang.String eventAsJson)
Deprecated.Since version 1.13.0.
Will be removed in version 1.16.0.
Please use
emit(OpenLineage.DatasetEvent)
oremit(OpenLineage.JobEvent)
instead
-
-