KinesisTransport (openlineage-java 1.21.0-SNAPSHOT API)

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 java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- KinesisTransport
  
  public KinesisTransport(@NonNull @NonNull com.amazonaws.services.kinesis.producer.KinesisProducer kinesisProducer, @NonNull @NonNull KinesisConfig kinesisConfig)
- KinesisTransport
  
  public KinesisTransport(@NonNull @NonNull KinesisConfig kinesisConfig)
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