Interface OpenLineageEventListener


  • 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 Detail

      • processOpenLineageRunEvent

        void processOpenLineageRunEvent​(OpenLineageRunEvent event,
                                        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:
        event - run event formatted using Egeria supplied beans (null if egeria can not format the event)
        rawEvent - json payload received for the event