Class APIBasedOpenLineageLogStoreConnector
java.lang.Object
org.odpi.openmetadata.frameworks.connectors.Connector
org.odpi.openmetadata.frameworks.connectors.ConnectorBase
org.odpi.openmetadata.frameworks.integration.connectors.IntegrationConnectorBase
org.odpi.openmetadata.integrationservices.lineage.connector.LineageIntegratorConnector
org.odpi.openmetadata.adapters.connectors.integration.openlineage.OpenLineageLogStoreConnectorBase
org.odpi.openmetadata.adapters.connectors.integration.openlineage.APIBasedOpenLineageLogStoreConnector
- All Implemented Interfaces:
OpenLineageLogStore
,AuditLoggingComponent
,SecureConnectorExtension
,VirtualConnectorExtension
,IntegrationConnector
,LineageIntegratorOMISConnector
,OpenLineageEventListener
APIBasedOpenLineageLogStoreConnector provides a connector implementation for an API based open lineage log.
Each lineage record is passed to the supplied lineage API.
-
Nested Class Summary
Nested classes/interfaces inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase
ConnectorBase.ProtectedConnection
-
Field Summary
Fields inherited from class org.odpi.openmetadata.adapters.connectors.integration.openlineage.OpenLineageLogStoreConnectorBase
destinationName, myContext
Fields inherited from class org.odpi.openmetadata.frameworks.integration.connectors.IntegrationConnectorBase
auditLog, connectorName, embeddedConnectors, integrationContext
Fields inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase
connectedAssetProperties, connectionBean, connectionProperties, connectorInstanceId, secretsStoreConnectorMap
-
Constructor Summary
ConstructorsConstructorDescriptionDefault constructor used by the connector provider. -
Method Summary
Modifier and TypeMethodDescriptionvoid
start()
Set up the name of the file storevoid
storeEvent
(OpenLineageRunEvent openLineageEvent, String rawEvent) Store the open lineage event in the open lineage log store.Methods inherited from class org.odpi.openmetadata.adapters.connectors.integration.openlineage.OpenLineageLogStoreConnectorBase
getDestinationName, initialize, logNoRawEvent, processOpenLineageRunEvent, refresh
Methods inherited from class org.odpi.openmetadata.integrationservices.lineage.connector.LineageIntegratorConnector
getContext, setContext
Methods inherited from class org.odpi.openmetadata.frameworks.integration.connectors.IntegrationConnectorBase
disconnect, engage, getConnectorComponentDescription, initializeEmbeddedConnectors, setAuditLog, setConnectorName, setContext
Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase
disconnectConnectors, equals, getConnectedAssetProperties, getConnection, getConnectorInstanceId, hashCode, initializeConnectedAssetProperties, initializeSecretsStoreConnector, isActive, toString
Methods inherited from class org.odpi.openmetadata.frameworks.connectors.Connector
clearStatisticProperty, clearStatisticTimestamp, getConnectorStatistics, getStatisticCounter, getStatisticProperty, getStatisticTimestamp, incrementStatisticCounter, initializeStatisticCounter, setStatisticProperty, setStatisticTimestamp
-
Constructor Details
-
APIBasedOpenLineageLogStoreConnector
public APIBasedOpenLineageLogStoreConnector()Default constructor used by the connector provider.
-
-
Method Details
-
start
Set up the name of the file store- Specified by:
start
in interfaceIntegrationConnector
- Overrides:
start
in classOpenLineageLogStoreConnectorBase
- Throws:
ConnectorCheckedException
- something went wrong
-
storeEvent
public 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.- Specified by:
storeEvent
in interfaceOpenLineageLogStore
- Specified by:
storeEvent
in classOpenLineageLogStoreConnectorBase
- Parameters:
openLineageEvent
- event formatted using Egeria beansrawEvent
- event in Json form from the originator - may have facets that are not known to Egeria- Throws:
InvalidParameterException
- indicates that the openLineageEvent parameter is invalidUserNotAuthorizedException
- indicates that the caller is not authorized to issue this rest callPropertyServerException
- indicates that the log store is not available or has an error
-