Package io.openlineage.client.transports

Class KinesisTransport

java.lang.Object

io.openlineage.client.transports.Transport

io.openlineage.client.transports.KinesisTransport

public class KinesisTransport
extends Transport

Constructor Summary

Constructors

Constructor	Description
KinesisTransport(@NonNull com.amazonaws.services.kinesis.producer.KinesisProducer kinesisProducer, @NonNull KinesisConfig kinesisConfig)
KinesisTransport(@NonNull KinesisConfig kinesisConfig)

Method Summary

Modifier and Type	Method	Description
void	emit(OpenLineage.DatasetEvent datasetEvent)
void	emit(OpenLineage.JobEvent jobEvent)
void	emit(OpenLineage.RunEvent runEvent)

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

emit

Methods inherited from class java.lang.Object

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

Constructor Detail

KinesisTransport

public KinesisTransport(@NonNull
                        @NonNull com.amazonaws.services.kinesis.producer.KinesisProducer kinesisProducer,
                        @NonNull
                        @NonNull KinesisConfig kinesisConfig)

KinesisTransport

public KinesisTransport(@NonNull
                        @NonNull KinesisConfig kinesisConfig)

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