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 the integration daemon.The GovernanceActionOpenLineageIntegrationProvider provides the connector provider for GovernanceActionOpenLineageIntegrationConnector.OpenLineageCataloguerIntegrationConnector receives OpenLineage events published to the integration daemon and catalogues what they describe in open metadata: Each OpenLineage job is matched to an existing process by namespace and resource name, or becomes a new process (DeployedSoftwareComponent).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.