diff --git a/static/apidocs/javadoc/index-all.html b/static/apidocs/javadoc/index-all.html index 50ca340..60e15dc 100644 --- a/static/apidocs/javadoc/index-all.html +++ b/static/apidocs/javadoc/index-all.html @@ -421,8 +421,16 @@

C

Factory class for creating new OpenLineageClient objects.
+
close() - Method in class io.openlineage.client.OpenLineageClient
+
 
+
close() - Method in class io.openlineage.client.transports.CompositeTransport
+
 
close() - Method in class io.openlineage.client.transports.HttpTransport
 
+
close() - Method in class io.openlineage.client.transports.KafkaTransport
+
 
+
close() - Method in class io.openlineage.client.transports.Transport
+
 
clusterName(String) - Method in class io.openlineage.client.OpenLineage.GcpDataprocSparkRunFacetBuilder
 
clusterUuid(String) - Method in class io.openlineage.client.OpenLineage.GcpDataprocSparkRunFacetBuilder
diff --git a/static/apidocs/javadoc/io/openlineage/client/OpenLineageClient.html b/static/apidocs/javadoc/io/openlineage/client/OpenLineageClient.html index 7f354fb..3ba2d7e 100644 --- a/static/apidocs/javadoc/io/openlineage/client/OpenLineageClient.html +++ b/static/apidocs/javadoc/io/openlineage/client/OpenLineageClient.html @@ -75,9 +75,14 @@

Class OpenLineageClient

io.openlineage.client.OpenLineageClient
+
+
All Implemented Interfaces:
+
AutoCloseable
+

public final class OpenLineageClient -extends Object
+extends Object +implements AutoCloseable
HTTP client used to emit OpenLineage.RunEvents to HTTP backend.
@@ -139,23 +144,26 @@

Method Summary

builder()
 
void
-
emit(OpenLineage.DatasetEvent datasetEvent)
-
-
Emit the given dataset event to HTTP backend.
-
+
close()
+
 
void
-
emit(OpenLineage.JobEvent jobEvent)
+
emit(OpenLineage.DatasetEvent datasetEvent)
-
Emit the given run event to HTTP backend.
+
Emit the given dataset event to HTTP backend.
void
-
emit(OpenLineage.RunEvent runEvent)
+
emit(OpenLineage.JobEvent jobEvent)
Emit the given run event to HTTP backend.
void
-
initializeMetrics()
-
 
+
emit(OpenLineage.RunEvent runEvent)
+
+
Emit the given run event to HTTP backend.
+
+
void
+
initializeMetrics()
+
 
@@ -268,6 +276,19 @@

builder

+
  • +
    +

    close

    +
    public void close() + throws Exception
    +
    +
    Specified by:
    +
    close in interface AutoCloseable
    +
    Throws:
    +
    Exception
    +
    +
    +
  • diff --git a/static/apidocs/javadoc/io/openlineage/client/package-tree.html b/static/apidocs/javadoc/io/openlineage/client/package-tree.html index c054998..3b9e943 100644 --- a/static/apidocs/javadoc/io/openlineage/client/package-tree.html +++ b/static/apidocs/javadoc/io/openlineage/client/package-tree.html @@ -180,7 +180,7 @@

    Class Hierarchy

  • io.openlineage.client.OpenLineage.SymlinksDatasetFacetBuilder (implements io.openlineage.client.OpenLineage.Builder<T>)
  • io.openlineage.client.OpenLineage.SymlinksDatasetFacetIdentifiers
  • io.openlineage.client.OpenLineage.SymlinksDatasetFacetIdentifiersBuilder (implements io.openlineage.client.OpenLineage.Builder<T>)
  • -
  • io.openlineage.client.OpenLineageClient
  • +
  • io.openlineage.client.OpenLineageClient (implements java.lang.AutoCloseable)
  • io.openlineage.client.OpenLineageClient.Builder
  • io.openlineage.client.OpenLineageClientUtils
  • io.openlineage.client.OpenLineageClientUtils.DisabledFacetsMixin
  • diff --git a/static/apidocs/javadoc/io/openlineage/client/transports/CompositeTransport.html b/static/apidocs/javadoc/io/openlineage/client/transports/CompositeTransport.html index a765da3..bac93b3 100644 --- a/static/apidocs/javadoc/io/openlineage/client/transports/CompositeTransport.html +++ b/static/apidocs/javadoc/io/openlineage/client/transports/CompositeTransport.html @@ -77,6 +77,10 @@

    Class CompositeTransport

    +
    +
    All Implemented Interfaces:
    +
    AutoCloseable
    +

    public class CompositeTransport extends Transport
    @@ -108,17 +112,20 @@

    Method Summary

    Method
    Description
    void
    -
    emit(OpenLineage.DatasetEvent datasetEvent)
    +
    close()
     
    void
    -
    emit(OpenLineage.JobEvent jobEvent)
    +
    emit(OpenLineage.DatasetEvent datasetEvent)
     
    void
    -
    emit(OpenLineage.RunEvent runEvent)
    +
    emit(OpenLineage.JobEvent jobEvent)
     
    -
    List<Transport>
    -
    getTransports()
    +
    void
    +
    emit(OpenLineage.RunEvent runEvent)
     
    +
    List<Transport>
    +
    getTransports()
    +
     
    @@ -190,6 +197,21 @@

    emit

    +
  • +
    +

    close

    +
    public void close() + throws Exception
    +
    +
    Specified by:
    +
    close in interface AutoCloseable
    +
    Overrides:
    +
    close in class Transport
    +
    Throws:
    +
    Exception
    +
    +
    +
  • diff --git a/static/apidocs/javadoc/io/openlineage/client/transports/ConsoleTransport.html b/static/apidocs/javadoc/io/openlineage/client/transports/ConsoleTransport.html index 618caf6..4bbfc0b 100644 --- a/static/apidocs/javadoc/io/openlineage/client/transports/ConsoleTransport.html +++ b/static/apidocs/javadoc/io/openlineage/client/transports/ConsoleTransport.html @@ -77,6 +77,10 @@

    Class ConsoleTransport

    +
    +
    All Implemented Interfaces:
    +
    AutoCloseable
    +

    public final class ConsoleTransport extends Transport
    @@ -120,6 +124,9 @@

    Method Summary

    +

    Methods inherited from class io.openlineage.client.transports.Transport

    +close
    +

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    diff --git a/static/apidocs/javadoc/io/openlineage/client/transports/FileTransport.html b/static/apidocs/javadoc/io/openlineage/client/transports/FileTransport.html index 586be79..86cebc3 100644 --- a/static/apidocs/javadoc/io/openlineage/client/transports/FileTransport.html +++ b/static/apidocs/javadoc/io/openlineage/client/transports/FileTransport.html @@ -77,6 +77,10 @@

    Class FileTransport

    +
    +
    All Implemented Interfaces:
    +
    AutoCloseable
    +

    public class FileTransport extends Transport
    @@ -123,6 +127,9 @@

    Method Summary

    +

    Methods inherited from class io.openlineage.client.transports.Transport

    +close
    +

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    diff --git a/static/apidocs/javadoc/io/openlineage/client/transports/HttpTransport.html b/static/apidocs/javadoc/io/openlineage/client/transports/HttpTransport.html index 54f1573..3c785fb 100644 --- a/static/apidocs/javadoc/io/openlineage/client/transports/HttpTransport.html +++ b/static/apidocs/javadoc/io/openlineage/client/transports/HttpTransport.html @@ -79,12 +79,11 @@

    Class HttpTransport

    All Implemented Interfaces:
    -
    Closeable, AutoCloseable
    +
    AutoCloseable

    public final class HttpTransport -extends Transport -implements Closeable
    +extends Transport
    diff --git a/static/apidocs/javadoc/io/openlineage/client/transports/KinesisTransport.html b/static/apidocs/javadoc/io/openlineage/client/transports/KinesisTransport.html index 8719752..cca0a0d 100644 --- a/static/apidocs/javadoc/io/openlineage/client/transports/KinesisTransport.html +++ b/static/apidocs/javadoc/io/openlineage/client/transports/KinesisTransport.html @@ -77,6 +77,10 @@

    Class KinesisTransport

    +
    +
    All Implemented Interfaces:
    +
    AutoCloseable
    +

    public class KinesisTransport extends Transport
    @@ -123,6 +127,9 @@

    Method Summary

    +

    Methods inherited from class io.openlineage.client.transports.Transport

    +close
    +

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    diff --git a/static/apidocs/javadoc/io/openlineage/client/transports/NoopTransport.html b/static/apidocs/javadoc/io/openlineage/client/transports/NoopTransport.html index 0fe645a..7ec71b8 100644 --- a/static/apidocs/javadoc/io/openlineage/client/transports/NoopTransport.html +++ b/static/apidocs/javadoc/io/openlineage/client/transports/NoopTransport.html @@ -77,6 +77,10 @@

    Class NoopTransport

    +
    +
    All Implemented Interfaces:
    +
    AutoCloseable
    +

    public class NoopTransport extends Transport
    @@ -120,6 +124,9 @@

    Method Summary

    +

    Methods inherited from class io.openlineage.client.transports.Transport

    +close
    +

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    diff --git a/static/apidocs/javadoc/io/openlineage/client/transports/Transport.html b/static/apidocs/javadoc/io/openlineage/client/transports/Transport.html index d662225..1c36015 100644 --- a/static/apidocs/javadoc/io/openlineage/client/transports/Transport.html +++ b/static/apidocs/javadoc/io/openlineage/client/transports/Transport.html @@ -76,12 +76,17 @@

    Class Transport

    +
    All Implemented Interfaces:
    +
    AutoCloseable
    +
    +
    Direct Known Subclasses:
    CompositeTransport, ConsoleTransport, FileTransport, HttpTransport, KafkaTransport, KinesisTransport, NoopTransport

    public abstract class Transport -extends Object
    +extends Object +implements AutoCloseable
    diff --git a/static/apidocs/javadoc/io/openlineage/client/transports/package-tree.html b/static/apidocs/javadoc/io/openlineage/client/transports/package-tree.html index 3793db7..282f640 100644 --- a/static/apidocs/javadoc/io/openlineage/client/transports/package-tree.html +++ b/static/apidocs/javadoc/io/openlineage/client/transports/package-tree.html @@ -91,12 +91,12 @@

    Class Hierarchy

    -
  • io.openlineage.client.transports.Transport +
  • io.openlineage.client.transports.Transport (implements java.lang.AutoCloseable)
  • -
  • io.openlineage.client.transports.Transport +
  • io.openlineage.client.transports.Transport (implements java.lang.AutoCloseable)