Package org.odpi.openmetadata.adapters.connectors.liskov

Class DataHubManagerTargetProcessor

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.liskov.DataHubManagerTargetProcessor

public class DataHubManagerTargetProcessor
extends CatalogTargetProcessorBase

Calculates the last time an update was made to the tabular data set that is the target and if it has changes 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
DataHubManagerTargetProcessor(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.

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

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

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

equals, getConnectorToTarget, getIntegrationContext, getNetworkAddress, hashCode, toString

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

getCatalogTargetElement, 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

DataHubManagerTargetProcessor

public DataHubManagerTargetProcessor(CatalogTarget catalogTarget,
 CatalogTargetContext catalogTargetContext,
 Connector connectorToTarget,
 String connectorName,
 AuditLog auditLog)

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

Method Details

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