Interface CatalogTargetIntegrator
- 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, 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, Connector connectorToTarget) throws ConnectorCheckedException Create a new catalog target processor (typically inherits from CatalogTargetProcessorBase).- Parameters:
retrievedCatalogTarget
- details of the open metadata elements describing the catalog targetconnectorToTarget
- connector to access the target resource- Returns:
- new processor based on the catalog target information
- Throws:
ConnectorCheckedException
-