Package io.debezium.openlineage.emitter

Interface LineageEmitter

All Known Implementing Classes:
NoOpLineageEmitter
public interface LineageEmitter

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
     
    void
    emit(io.debezium.connector.common.DebeziumTaskState state)
     
    void
    emit(io.debezium.connector.common.DebeziumTaskState state, Throwable t)
     
    void
    emit(io.debezium.connector.common.DebeziumTaskState state, List<DatasetMetadata> datasetMetadata)
     
    void
    emit(io.debezium.connector.common.DebeziumTaskState state, List<DatasetMetadata> datasetMetadata, Throwable t)
     

  • Method Details

    • emit

      void emit(io.debezium.connector.common.DebeziumTaskState state)

    • emit

      void emit(io.debezium.connector.common.DebeziumTaskState state, Throwable t)

    • emit

      void emit(io.debezium.connector.common.DebeziumTaskState state, List<DatasetMetadata> datasetMetadata)

    • emit

      void emit(io.debezium.connector.common.DebeziumTaskState state, List<DatasetMetadata> datasetMetadata, Throwable t)

    • close

      void close()