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

Class OpenLineageEventReceiverCatalogTargetProcessor

java.lang.Object

org.odpi.openmetadata.frameworks.governanceaction.properties.CatalogTargetProperties

org.odpi.openmetadata.frameworks.governanceaction.properties.CatalogTarget

org.odpi.openmetadata.frameworks.integration.properties.RequestedCatalogTarget

org.odpi.openmetadata.frameworks.integration.connectors.CatalogTargetProcessorBase

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

public class OpenLineageEventReceiverCatalogTargetProcessor
extends CatalogTargetProcessorBase

Listens for events from Apache Kafka that contain open lineage events.

Field Summary

Fields inherited from class org.odpi.openmetadata.frameworks.integration.connectors.CatalogTargetProcessorBase

auditLog, connectorName, propertyHelper

Fields inherited from class org.odpi.openmetadata.frameworks.integration.properties.RequestedCatalogTarget

connectorToTarget, integrationContext

Constructor Summary

Constructors

Constructor	Description
OpenLineageEventReceiverCatalogTargetProcessor(CatalogTarget template, CatalogTargetContext catalogTargetContext, Connector connectorToTarget, String connectorName, AuditLog auditLog, OpenMetadataTopicListener listener)	Copy/clone constructor

Method Summary

Modifier and Type	Method	Description
void	refresh()	Requests that the connector does a comparison of the metadata in the third party technology and open metadata repositories.

Methods inherited from class org.odpi.openmetadata.frameworks.integration.connectors.CatalogTargetProcessorBase

getDateConfigurationProperty, getStringConfigurationProperty

Methods inherited from class org.odpi.openmetadata.frameworks.integration.properties.RequestedCatalogTarget

equals, getConnectorToTarget, getIntegrationContext, hashCode, toString

Methods inherited from class org.odpi.openmetadata.frameworks.governanceaction.properties.CatalogTarget

getCatalogTargetElement, getRelationshipGUID, getRelationshipVersions, setCatalogTargetElement, setRelationshipGUID, setRelationshipVersions

Methods inherited from class org.odpi.openmetadata.frameworks.governanceaction.properties.CatalogTargetProperties

getCatalogTargetName, getConfigurationProperties, getConnectionName, getDeleteMethod, getMetadataSourceQualifiedName, getPermittedSynchronization, getTemplateProperties, setCatalogTargetName, setConfigurationProperties, setConnectionName, setDeleteMethod, setMetadataSourceQualifiedName, setPermittedSynchronization, setTemplateProperties

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

OpenLineageEventReceiverCatalogTargetProcessor

public OpenLineageEventReceiverCatalogTargetProcessor(CatalogTarget template,
 CatalogTargetContext catalogTargetContext,
 Connector connectorToTarget,
 String connectorName,
 AuditLog auditLog,
 OpenMetadataTopicListener listener)
                                               throws ConnectorCheckedException,
UserNotAuthorizedException

Copy/clone constructor

Parameters:

template - object to copy

catalogTargetContext - specialized context for this catalog target

connectorToTarget - connector to access the target resource

connectorName - name of this integration connector

auditLog - logging destination

listener - listener

Throws:

ConnectorCheckedException - there is a problem within the connector.

UserNotAuthorizedException - the connector was disconnected before/during start

Method Details

refresh

public void refresh()

Requests that the connector does a comparison of the metadata in the third party technology and open metadata repositories. Refresh is called when the integration connector first starts and then at intervals defined in the connector's configuration as well as any external REST API calls to explicitly refresh the connector.

Specified by:

refresh in class CatalogTargetProcessorBase