Interface CatalogTargetIntegrator
- All Known Subinterfaces:
CatalogTargetEventProcessor
- All Known Implementing Classes:
DistributeAuditEventsFromKafkaConnector
,HarvestOpenMetadataConnector
,HarvestSurveysConnector
,JDBCIntegrationConnector
,KafkaTopicIntegrationConnector
,OpenLineageEventReceiverIntegrationConnector
,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 TypeMethodDescriptiondefault 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 targetcatalogTargetContext
- specialized context for this catalog targetconnectorToTarget
- connector to access the target resource- Returns:
- new processor based on the catalog target information
- Throws:
ConnectorCheckedException
- problem setting up targetUserNotAuthorizedException
- the connector was disconnected before/during start
-