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
void	storeEvent(OpenLineageRunEvent openLineageEvent, String rawEvent, String destinationAddress)	Store the open lineage event in the open lineage log store.

Method Details

storeEvent

void storeEvent(OpenLineageRunEvent openLineageEvent,
 String rawEvent,
 String destinationAddress)
         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

destinationAddress - destination address

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.