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

Interface OpenLineageListenerManager

All Known Implementing Classes:
LineageIntegratorContext, LineageIntegratorContextManager
public interface OpenLineageListenerManager
Interface that supports the connector registering an listener for the open lineage events.

  • Method Details

    • registerListener

      void registerListener(OpenLineageEventListener listener)
      The listener is implemented by the integration connector. Once it is registered with the context, its processOpenLineageRunEvent() method is called each time an open lineage event is published to the Lineage Integrator OMIS.
      Parameters:
      listener - listener to call

    • publishOpenLineageRunEvent

      void publishOpenLineageRunEvent(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:
      rawEvent - json payload received for the event

    • publishOpenLineageRunEvent

      void publishOpenLineageRunEvent(OpenLineageRunEvent event)
      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 - bean for the event