Interface OpenLineageListenerManager

    • Method Detail

      • 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​(java.lang.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