Package org.odpi.openmetadata.integrationservices.lineage.connector

Interface OpenLineageEventListener

All Known Implementing Classes:
APIBasedOpenLineageLogStoreConnector, FileBasedOpenLineageLogStoreConnector, OpenLineageCataloguerIntegrationConnector, OpenLineageLogStoreConnectorBase
public interface OpenLineageEventListener
OpenLineageEventListener is implemented by an integration connector that wishes to receive open lineage events as they are sent to the Lineage Integrator OMIS.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    processOpenLineageRunEvent(OpenLineageRunEvent event, String rawEvent)
    Called each time an open lineage run event is published to the Lineage Integrator OMIS.

  • Method Details

    • processOpenLineageRunEvent

      void processOpenLineageRunEvent(OpenLineageRunEvent event, String rawEvent)
      Called each time an open lineage run event is published to the Lineage Integrator OMIS. The integration connector is able to work with the formatted event using the Egeria beans or reformat the open lineage run event using the supplied open lineage backend beans or another set of beans.
      Parameters:
      event - run event formatted using Egeria supplied beans (null if egeria can not format the event)
      rawEvent - json payload received for the event