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

Class RequestedCatalogTargetsManager

java.lang.Object

org.odpi.openmetadata.frameworks.integration.connectors.RequestedCatalogTargetsManager

All Implemented Interfaces:

CatalogTargetChangeListener

public class RequestedCatalogTargetsManager
extends Object
implements CatalogTargetChangeListener

Manages the map of catalog targets that this integration connector is working with.

Constructor Summary

Constructors

Constructor	Description
RequestedCatalogTargetsManager(Map<String,Object> connectorConfigProperties, String connectorName, AuditLog auditLog)	Constructor - passed the values from the integration connector that are needed by each catalog target,

Method Summary

Modifier and Type	Method	Description
void	disconnect()	Shutdown event monitoring
List<RequestedCatalogTarget>	getRequestedCatalogTargets()	Return list of the current catalog targets
void	newCatalogTarget(RequestedCatalogTarget catalogTarget)	This catalog target has been created since the last refresh.
List<RequestedCatalogTarget>	refreshKnownCatalogTargets(IntegrationContext integrationContext, CatalogTargetIntegrator catalogTargetIntegrator)	Return a list of requested catalog targets for the connector.
void	removedCatalogTarget(RequestedCatalogTarget catalogTarget)	This catalog target has been removed from the connector.
void	updatedCatalogTarget(RequestedCatalogTarget oldCatalogTarget, RequestedCatalogTarget newCatalogTarget)	This catalog target has new properties.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

RequestedCatalogTargetsManager

public RequestedCatalogTargetsManager(Map<String,Object> connectorConfigProperties,
 String connectorName,
 AuditLog auditLog)

Constructor - passed the values from the integration connector that are needed by each catalog target,

Parameters:

connectorConfigProperties - base configuration properties - these are overlaid with the config properties from the catalog target relationship

connectorName - can of this connector for error messages

auditLog - audit log for this connector

Method Details

refreshKnownCatalogTargets

public List<RequestedCatalogTarget> refreshKnownCatalogTargets(IntegrationContext integrationContext,
 CatalogTargetIntegrator catalogTargetIntegrator)
                                                        throws ConnectorCheckedException

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

Parameters:

integrationContext - the integration component that will process each catalog target

catalogTargetIntegrator - subclass of connector implementation

Throws:

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

getRequestedCatalogTargets

public List<RequestedCatalogTarget> getRequestedCatalogTargets()

Return list of the current catalog targets

Returns:

list of the current catalog targets

newCatalogTarget

public void newCatalogTarget(RequestedCatalogTarget catalogTarget)

This catalog target has been created since the last refresh.

Specified by:

newCatalogTarget in interface CatalogTargetChangeListener

Parameters:

catalogTarget - new catalog target

updatedCatalogTarget

public void updatedCatalogTarget(RequestedCatalogTarget oldCatalogTarget,
 RequestedCatalogTarget newCatalogTarget)

This catalog target has new properties.

Specified by:

updatedCatalogTarget in interface CatalogTargetChangeListener

Parameters:

oldCatalogTarget - old values

newCatalogTarget - new values

removedCatalogTarget

public void removedCatalogTarget(RequestedCatalogTarget catalogTarget)

This catalog target has been removed from the connector.

Specified by:

removedCatalogTarget in interface CatalogTargetChangeListener

Parameters:

catalogTarget - removed relationship

disconnect

public void disconnect()
                throws ConnectorCheckedException

Shutdown event monitoring

Throws:

ConnectorCheckedException - something failed in the super class