Package org.odpi.openmetadata.integrationservices.catalog.connector

Class CatalogIntegratorConnector

java.lang.Object

org.odpi.openmetadata.frameworks.connectors.Connector

org.odpi.openmetadata.frameworks.connectors.ConnectorBase

org.odpi.openmetadata.frameworks.integration.connectors.IntegrationConnectorBase

org.odpi.openmetadata.integrationservices.catalog.connector.CatalogIntegratorConnector

All Implemented Interfaces:

AuditLoggingComponent, SecureConnectorExtension, VirtualConnectorExtension, IntegrationConnector, CatalogIntegratorOMISConnector

Direct Known Subclasses:

ApacheAtlasIntegrationConnector, DistributeAuditEventsFromKafkaConnector, HarvestOpenMetadataConnector, HarvestSurveysConnector, OSSUnityCatalogInsideCatalogSyncConnector, OSSUnityCatalogServerSyncConnector

public abstract class CatalogIntegratorConnector
extends IntegrationConnectorBase
implements CatalogIntegratorOMISConnector

CatalogIntegratorConnector is the base class for an integration connector that is managed by the Catalog Integrator OMIS.

Nested Class Summary

Nested classes/interfaces inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

ConnectorBase.ProtectedConnection

Field Summary

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

auditLog, catalogTargetsManager, connectorName, integrationContext, propertyHelper

Fields inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

connectedAssetProperties, connectionBean, connectionProperties, connectorInstanceId, embeddedConnectors, messageFormatter, secretsStoreConnectorMap

Constructor Summary

Constructors

Constructor	Description
CatalogIntegratorConnector()

Method Summary

Modifier and Type	Method	Description
CatalogIntegratorContext	getContext()	Return the context for this connector.
protected void	passEventToCatalogTargets(CatalogTargetEventProcessor catalogTargetEventProcessor, AssetManagerOutTopicEvent event)	Return a list of requested catalog targets for the connector.
void	setContext(CatalogIntegratorContext context)	Set up the context for this connector.

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

disconnect, engage, getConnectorComponentDescription, getNetworkAddress, refreshCatalogTargets, registerCatalogTargetChangeListener, setAuditLog, setConnectorName, setContext, start

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

combineConfigurationProperties, disconnectConnectors, equals, getArrayConfigurationProperty, getAssetTypeName, getBooleanConfigurationProperty, getConnectedAssetProperties, getConnection, getConnectorInstanceId, getDateConfigurationProperty, getIntConfigurationProperty, getLongConfigurationProperty, getNetworkAddresses, getStringConfigurationProperty, getSuppliedPlaceholderProperties, hashCode, initialize, initializeConnectedAssetProperties, initializeEmbeddedConnectors, initializeSecretsStoreConnector, isActive, logExceptionRecord, logRecord, logRecord, throwMissingConfigurationProperty, throwMissingResource, throwNoAsset, throwWrongTypeOfAsset, throwWrongTypeOfResource, throwWrongTypeOfRootSchema, toString

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.Connector

clearStatisticProperty, clearStatisticTimestamp, getConnectorStatistics, getStatisticCounter, getStatisticProperty, getStatisticTimestamp, incrementStatisticCounter, initializeStatisticCounter, setStatisticProperty, setStatisticTimestamp

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.odpi.openmetadata.frameworks.integration.connectors.IntegrationConnector

refresh

Methods inherited from interface org.odpi.openmetadata.frameworks.connectors.VirtualConnectorExtension

initializeEmbeddedConnectors

Constructor Details

CatalogIntegratorConnector

public CatalogIntegratorConnector()

Method Details

setContext

public void setContext(CatalogIntegratorContext context)

Set up the context for this connector. It is called by the context manager.

Parameters:

context - context for this connector's private use.

getContext

public CatalogIntegratorContext getContext()
                                    throws ConnectorCheckedException

Return the context for this connector. It is called by the connector.

Returns:

context for this connector's private use.

Throws:

ConnectorCheckedException - internal issue setting up context

passEventToCatalogTargets

protected void passEventToCatalogTargets(CatalogTargetEventProcessor catalogTargetEventProcessor,
 AssetManagerOutTopicEvent event)
                                  throws ConnectorCheckedException

Return a list of requested catalog targets for the connector. These are extracted from the metadata store.

Parameters:

catalogTargetEventProcessor - the integration component that will process each catalog target

event - event to process

Throws:

ConnectorCheckedException - there is a problem with the connector. It is not able to refresh the metadata.