Package org.odpi.openmetadata.adapters.connectors.jacquard

Class JacquardCatalogTargetProcessor

java.lang.Object

org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipProperties

org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipBeanProperties

org.odpi.openmetadata.frameworks.openmetadata.properties.assets.processes.connectors.CatalogTargetProperties

org.odpi.openmetadata.frameworks.opengovernance.properties.CatalogTarget

org.odpi.openmetadata.frameworks.integration.properties.RequestedCatalogTarget

org.odpi.openmetadata.frameworks.integration.connectors.CatalogTargetProcessorBase

org.odpi.openmetadata.adapters.connectors.jacquard.JacquardCatalogTargetProcessor

public class JacquardCatalogTargetProcessor
extends CatalogTargetProcessorBase

Calculates the last time an update was made to the tabular data set that is the target and if it has changed since the last refresh (or this is the first refresh), the DataScope classification is updated with the latest update time. This will be detected as a change to the catalog target by any monitoring process.

Field Summary

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

auditLog, connectorName, metadataCollectionGUID, metadataCollectionName, propertyHelper

Fields inherited from class org.odpi.openmetadata.frameworks.integration.properties.RequestedCatalogTarget

connectorToTarget, integrationContext

Fields inherited from class org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipBeanProperties

typeName

Constructor Summary

Constructors

Constructor	Description
JacquardCatalogTargetProcessor(CatalogTarget catalogTarget, CatalogTargetContext catalogTargetContext, Connector connectorToTarget, String connectorName, AuditLog auditLog)	Constructor

Method Summary

Modifier and Type	Method	Description
void	refresh()	Check whether the data set has changed since the last refresh.
void	start()	Start the processor, and with it the connector to the product's data set.

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

disconnect, getArrayConfigurationProperty, getArrayConfigurationProperty, getArrayConfigurationProperty, getBooleanConfigurationProperty, getCatalogTargetElement, getDateConfigurationProperty, getHostIdentifier, getIntConfigurationProperty, getLongConfigurationProperty, getPortNumber, getStringConfigurationProperty, getSuppliedPlaceholderProperties, setUpMetadataSource, setUpSoftwareCapability, throwBadBeanClass, throwMissingConnectionInfo, throwMissingPropertyValue, throwWrongTypeOfCatalogTarget, throwWrongTypeOfResourceConnector

Methods inherited from class org.odpi.openmetadata.frameworks.integration.properties.RequestedCatalogTarget

clearRetrievedCatalogTargetElement, equals, getCatalogTargetElement, getCatalogTargetElementHeader, getCatalogTargetElementRetrievalException, getConnectorToTarget, getIntegrationContext, getNetworkAddress, hashCode, toString

Methods inherited from class org.odpi.openmetadata.frameworks.opengovernance.properties.CatalogTarget

getRelationshipGUID, getRelationshipVersions, setCatalogTargetElement, setRelationshipGUID, setRelationshipVersions

Methods inherited from class org.odpi.openmetadata.frameworks.openmetadata.properties.assets.processes.connectors.CatalogTargetProperties

getCatalogTargetName, getConfigurationProperties, getConnectionName, getDeleteMethod, getMetadataCollectionQualifiedName, getMetadataSourceQualifiedName, getPermittedSynchronization, getTemplates, setCatalogTargetName, setConfigurationProperties, setConnectionName, setDeleteMethod, setMetadataCollectionQualifiedName, setMetadataSourceQualifiedName, setPermittedSynchronization, setTemplates

Methods inherited from class org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipBeanProperties

getExtendedProperties, getTypeName, setExtendedProperties, setTypeName

Methods inherited from class org.odpi.openmetadata.frameworks.openmetadata.properties.RelationshipProperties

getEffectiveFrom, getEffectiveTo, setEffectiveFrom, setEffectiveTo

Methods inherited from class java.lang.Object

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

Constructor Details

JacquardCatalogTargetProcessor

public JacquardCatalogTargetProcessor(CatalogTarget catalogTarget,
 CatalogTargetContext catalogTargetContext,
 Connector connectorToTarget,
 String connectorName,
 AuditLog auditLog)
                               throws ConnectorCheckedException,
UserNotAuthorizedException

Constructor

Parameters:

catalogTarget - catalog target information

catalogTargetContext - specialized context for this catalog target

connectorToTarget - connector to access the target resource

connectorName - name of this integration connector

auditLog - logging destination

Throws:

ConnectorCheckedException - error

UserNotAuthorizedException - the connector is disconnected

Method Details

start

public void start()
           throws ConnectorCheckedException,
UserNotAuthorizedException

Start the processor, and with it the connector to the product's data set.

The targets manager starts every new processor while it is still retrieving the catalog targets, before the connector's refresh has done anything else. Starting the data source opens a connection to the platform named in the product's connection, and a product whose connection named a platform that had moved failed here - and the failure, thrown, aborted the whole refresh: no other product was refreshed, and the harvest that repairs such connections was never reached, so the product could never recover.

A failure to start the data source is therefore logged against this product and kept, not thrown. The refresh tries again each cycle and, while it keeps failing, skips this product and no other.

Overrides:

start in class CatalogTargetProcessorBase

Throws:

ConnectorCheckedException - a problem in the framework's own start-up

UserNotAuthorizedException - the connector has been disconnected

refresh

public void refresh()
             throws ConnectorCheckedException,
UserNotAuthorizedException

Check whether the data set has changed since the last refresh. If it has then update the asset's DataScope classification.

Overrides:

refresh in class CatalogTargetProcessorBase

Throws:

ConnectorCheckedException - a problem with the connector. It is unable to refresh the metadata.

UserNotAuthorizedException - the connector was disconnected so stop refresh processing