Package io.openlineage.client.transports

Class HttpTransport

java.lang.Object

io.openlineage.client.transports.Transport

io.openlineage.client.transports.HttpTransport

All Implemented Interfaces:

Closeable, AutoCloseable

public final class HttpTransport
extends Transport
implements Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static final class	HttpTransport.Builder	Deprecated. Use HttpConfig instead

Constructor Summary

Constructors

Constructor	Description
HttpTransport(@NonNull HttpConfig httpConfig)
HttpTransport(@NonNull org.apache.http.impl.client.CloseableHttpClient httpClient, @NonNull HttpConfig httpConfig)

Method Summary

Modifier and Type	Method	Description
static HttpTransport.Builder	builder()
void	close()
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

HttpTransport

public HttpTransport(@NonNull
 @NonNull HttpConfig httpConfig)

HttpTransport

public HttpTransport(@NonNull
 @NonNull org.apache.http.impl.client.CloseableHttpClient httpClient,
 @NonNull
 @NonNull HttpConfig httpConfig)

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

close

public void close()
           throws IOException

Specified by:

close in interface AutoCloseable

Specified by:

close in interface Closeable

Throws:

IOException

builder

public static HttpTransport.Builder builder()

Returns:

an new HttpTransport.Builder object for building HttpTransports.