Package org.odpi.openmetadata.adapters.connectors.integration.openlineage

Interface OpenLineageLogStore

All Known Implementing Classes:
APIBasedOpenLineageLogStoreConnector, FileBasedOpenLineageLogStoreConnector, OpenLineageLogStoreConnectorBase
public interface OpenLineageLogStore
OpenLineageLogStore is the specialized data API for an Open Lineage Log Store destination connector.

  • Method Summary

    Modifier and Type
    Method
    Description
    String
    getDestinationName()
    Return the name of this destination.
    void
    storeEvent(OpenLineageRunEvent openLineageEvent, String rawEvent)
    Store the open lineage event in the open lineage log store.

  • Method Details

    • getDestinationName

      String getDestinationName()
      Return the name of this destination.
      Returns:
      string display name suitable for messages.

    • storeEvent

      void storeEvent(OpenLineageRunEvent openLineageEvent, String rawEvent) throws InvalidParameterException, UserNotAuthorizedException, PropertyServerException
      Store the open lineage event in the open lineage log store. If the raw event is null, a json version of the open lineage event is generated using the Egeria beans.
      Parameters:
      openLineageEvent - event formatted using Egeria beans
      rawEvent - event in Json form from the originator - may have facets that are not known to Egeria
      Throws:
      InvalidParameterException - indicates that the openLineageEvent parameter is invalid.
      UserNotAuthorizedException - indicates that the caller is not authorized to access the log store.
      PropertyServerException - indicates that the log store is not available or has an error.