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 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 target
      connectorToTarget - connector to access the target resource
      Returns:
      new processor based on the catalog target information
      Throws:
      ConnectorCheckedException