Package org.odpi.openmetadata.adapters.connectors.integration.openlineage
package org.odpi.openmetadata.adapters.connectors.integration.openlineage
The open lineage integration connectors work with open lineage events and either process or distribute them.
-
ClassDescriptionAPIBasedOpenLineageLogStoreConnector provides a connector implementation for an API based open lineage log.APIBasedOpenLineageLogStoreProvider is the OCF connector provider for the API based open lineage log store.FileBasedOpenLineageLogStoreConnector provides a connector implementation for a file based open lineage log.FileBasedOpenLineageLogStoreProvider is the OCF connector provider for the file based open lineage log store.GovernanceActionOpenLineageIntegrationConnector is an integration connector to listen for governance actions executing in the open metadata ecosystem, generate open lineage events for them and publish them to any integration connector running in the same instance of Lineage Integration OMIS.The GovernanceActionOpenLineageIntegrationProvider provides the connector provider for GovernanceActionOpenLineageIntegrationConnector.OpenLineageCataloguerIntegrationConnector is an integration connector to register an OpenLineage listener with the Lineage Integrator OMIS and to catalog any processes that are not already known to the open metadata ecosystem.The OpenLineageCataloguerIntegrationProvider provides the connector provider for OpenLineageCataloguerIntegrationConnector.Listens for events from Apache Kafka that contain open lineage events.OpenLineageEventReceiverIntegrationConnector receives open lineage events from an event broker such as an Apache Kafka topic.OpenLineageEventReceiverIntegrationProvider is the connector provider for the OpenLineageEventReceiverIntegrationConnector.OpenLineageLogStore is the specialized data API for an Open Lineage Log Store destination connector.OpenLineageLogStoreConnectorBase is the base class for connectors that support the OMRSAuditLog.