Package org.odpi.openmetadata.frameworks.integration.connectors

Interface CatalogTargetIntegrator

All Known Subinterfaces:

CatalogTargetEventProcessor

All Known Implementing Classes:

DistributeAuditEventsFromKafkaConnector, HarvestOpenMetadataConnector, HarvestSurveysConnector, JDBCIntegrationConnector, KafkaTopicIntegrationConnector, OpenLineageEventReceiverIntegrationConnector, OpenMetadataProductsHarvesterConnector, OSSUnityCatalogInsideCatalogSyncConnector, OSSUnityCatalogServerSyncConnector, PostgresServerIntegrationConnector

public interface CatalogTargetIntegrator

CatalogTargetIntegrator is an optional interface that an integration connector can implement to walk through the catalog targets assigned to the integration connector.

Method Summary

Modifier and Type	Method	Description
default RequestedCatalogTarget	getNewRequestedCatalogTargetSkeleton(CatalogTarget retrievedCatalogTarget, CatalogTargetContext catalogTargetContext, Connector connectorToTarget)	Create a new catalog target processor (typically inherits from CatalogTargetProcessorBase).
void	integrateCatalogTarget(RequestedCatalogTarget requestedCatalogTarget)	Perform the required integration logic for the assigned catalog target.

Method Details

integrateCatalogTarget

void integrateCatalogTarget(RequestedCatalogTarget requestedCatalogTarget)
                     throws ConnectorCheckedException

Perform the required integration logic for the assigned catalog target.

Parameters:

requestedCatalogTarget - the catalog target

Throws:

ConnectorCheckedException - there is an unrecoverable error and the connector should stop processing.

getNewRequestedCatalogTargetSkeleton

default RequestedCatalogTarget getNewRequestedCatalogTargetSkeleton(CatalogTarget retrievedCatalogTarget,
 CatalogTargetContext catalogTargetContext,
 Connector connectorToTarget)
                                                             throws ConnectorCheckedException,
UserNotAuthorizedException

Create a new catalog target processor (typically inherits from CatalogTargetProcessorBase).

Parameters:

retrievedCatalogTarget - details of the open metadata elements describing the catalog target

catalogTargetContext - specialized context for this catalog target

connectorToTarget - connector to access the target resource

Returns:

new processor based on the catalog target information

Throws:

ConnectorCheckedException - problem setting up target

UserNotAuthorizedException - the connector was disconnected before/during start