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()
void	close()
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.

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(@NonNull
                 OpenLineage.DatasetEvent datasetEvent)

Overrides:

emit in class Transport

emit

public void emit(@NonNull
                 OpenLineage.JobEvent jobEvent)

Overrides:

emit in class Transport

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) or emit(OpenLineage.JobEvent) instead

Overrides:

emit in class Transport

Parameters:

eventAsJson - string json event

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.