Package io.openlineage.client.transports

Class HttpTransport

java.lang.Object

io.openlineage.client.transports.Transport

io.openlineage.client.transports.HttpTransport

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable

public final class HttpTransport
extends Transport
implements java.io.Closeable

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static 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()	Returns an new HttpTransport.Builder object for building HttpTransports.
void	close()
void	emit(OpenLineage.RunEvent runEvent)
void	emit(java.lang.String eventAsJson)

Methods inherited from class java.lang.Object

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

Constructor Detail

HttpTransport

public HttpTransport(@NonNull
                     @NonNull HttpConfig httpConfig)

HttpTransport

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

Method Detail

emit

public void emit(@NonNull
                 OpenLineage.RunEvent runEvent)

Specified by:

emit in class Transport

emit

public void emit(java.lang.String eventAsJson)

Overrides:

emit in class Transport

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface java.io.Closeable

Throws:

java.io.IOException

builder

public static HttpTransport.Builder builder()

Returns an new HttpTransport.Builder object for building HttpTransports.