Package org.odpi.openmetadata.adapters.connectors.unitycatalog.sync

Class OSSUnityCatalogInsideCatalogSyncVolumes

java.lang.Object

org.odpi.openmetadata.frameworks.auditlog.AuditLoggingBase

org.odpi.openmetadata.adapters.connectors.unitycatalog.sync.OSSUnityCatalogInsideCatalogSyncBase

org.odpi.openmetadata.adapters.connectors.unitycatalog.sync.OSSUnityCatalogInsideCatalogSyncVolumes

public class OSSUnityCatalogInsideCatalogSyncVolumes
extends OSSUnityCatalogInsideCatalogSyncBase

Provides the specialist methods for working with Unity Catalog (UC) Volumes.

Field Summary

Fields

Modifier and Type	Field	Description
protected String	canonicalMountPoint
protected String	fileSystemName
protected String	localMountPoint
protected String	unityMountPoint

Fields inherited from class org.odpi.openmetadata.adapters.connectors.unitycatalog.sync.OSSUnityCatalogInsideCatalogSyncBase

assetClient, catalogGUID, catalogTargetName, catalogTypeName, configurationProperties, connectorName, context, deployedImplementationType, entityTypeName, excludeNames, externalIdClient, includeNames, metadataCollectionGUID, metadataCollectionQualifiedName, openMetadataStore, propertyFacetClient, propertyHelper, serverGUID, targetPermittedSynchronization, templateGUID, templates, ucConnector, ucFullNameToEgeriaGUID, ucServerEndpoint

Fields inherited from class org.odpi.openmetadata.frameworks.auditlog.AuditLoggingBase

auditLog

Constructor Summary

Constructors

Constructor

Description

OSSUnityCatalogInsideCatalogSyncVolumes(String connectorName, IntegrationContext context, String catalogTargetName, String serverGUID, String catalogGUID, String metadataCollectionGUID, String catalogName, Map<String,String> ucFullNameToEgeriaGUID, PermittedSynchronization targetPermittedSynchronization, OSSUnityCatalogResourceConnector ucConnector, String ucServerEndpoint, Map<String,String> templates, Map<String,Object> configurationProperties, List<String> excludeNames, List<String> includeNames, AuditLog auditLog)

Set up the volume synchronizer.

Method Summary

Modifier and Type	Method	Description
protected IntegrationIterator	refreshEgeria(String parentGUID, String parentRelationshipTypeName, RelationshipBeanProperties relationshipProperties)	Review all the volumes stored in Egeria.
protected void	refreshUnityCatalog(String parentGUID, String parentRelationshipTypeName, RelationshipBeanProperties relationshipProperties, IntegrationIterator iterator)	Review all the volumes stored in UC.

Methods inherited from class org.odpi.openmetadata.adapters.connectors.unitycatalog.sync.OSSUnityCatalogInsideCatalogSyncBase

addExternalIdentifier, addPropertyFacet, buildAnchorScopeGUIDs, deleteElementInEgeria, findExistingSchemaAttribute, findExistingSchemaType, getArrayConfigurationProperty, getCleanStorageLocation, getDateFromLong, getExternalIdLinkProperties, getExternalIdProperties, getParentGUIDFromMember, getQualifiedName, getShortName, getUCCatalogFromMember, getUCCommentFomMember, getUCNameFromMember, getUCPropertiesFromMember, getUCSchemaFromMember, getUCStorageLocationFromMember, noMismatchInExternalIdentifier, shouldBeCatalogued, throwBadBeanClass, throwMissingPropertyValue

Methods inherited from class org.odpi.openmetadata.frameworks.auditlog.AuditLoggingBase

logExceptionRecord, logExceptionRecord, logRecord, logRecord

Methods inherited from class java.lang.Object

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

Field Details

fileSystemName

protected String fileSystemName

localMountPoint

protected String localMountPoint

canonicalMountPoint

protected String canonicalMountPoint

unityMountPoint

protected String unityMountPoint

Constructor Details

OSSUnityCatalogInsideCatalogSyncVolumes

public OSSUnityCatalogInsideCatalogSyncVolumes(String connectorName,
 IntegrationContext context,
 String catalogTargetName,
 String serverGUID,
 String catalogGUID,
 String metadataCollectionGUID,
 String catalogName,
 Map<String,String> ucFullNameToEgeriaGUID,
 PermittedSynchronization targetPermittedSynchronization,
 OSSUnityCatalogResourceConnector ucConnector,
 String ucServerEndpoint,
 Map<String,String> templates,
 Map<String,Object> configurationProperties,
 List<String> excludeNames,
 List<String> includeNames,
 AuditLog auditLog)
                                        throws UserNotAuthorizedException,
InvalidParameterException

Set up the volume synchronizer.

Parameters:

connectorName - name of this connector

context - context for the connector

catalogTargetName - the catalog target name

serverGUID - guid of the UC server asset

catalogGUID - guid of the catalog

metadataCollectionGUID - guid of the metadata collection for this server

catalogName - name of the catalog

ucFullNameToEgeriaGUID - map of full names from UC to the GUID of the entity in Egeria.

targetPermittedSynchronization - the policy that controls the direction of metadata exchange

ucConnector - connector for accessing UC

ucServerEndpoint - the server endpoint used to constructing the qualified names

templates - templates supplied through the catalog target

configurationProperties - configuration properties supplied through the catalog target

excludeNames - list of volumes to ignore (and include all others)

includeNames - list of volumes to include (and ignore all others) - overrides excludeNames

auditLog - logging destination

Throws:

UserNotAuthorizedException - the connector was disconnected before/during start

InvalidParameterException

Method Details

refreshEgeria

protected IntegrationIterator refreshEgeria(String parentGUID,
 String parentRelationshipTypeName,
 RelationshipBeanProperties relationshipProperties)
                                     throws InvalidParameterException,
PropertyServerException,
UserNotAuthorizedException,
ConnectorCheckedException

Review all the volumes stored in Egeria.

Specified by:

refreshEgeria in class OSSUnityCatalogInsideCatalogSyncBase

Parameters:

parentGUID - unique identifier of the parent

parentRelationshipTypeName - relationship type between parent and elements to iterate through

relationshipProperties - optional properties for the relationship

Returns:

iterator

Throws:

InvalidParameterException - parameter error

PropertyServerException - repository error

UserNotAuthorizedException - security error

ConnectorCheckedException - logic error in properties

refreshUnityCatalog

protected void refreshUnityCatalog(String parentGUID,
 String parentRelationshipTypeName,
 RelationshipBeanProperties relationshipProperties,
 IntegrationIterator iterator)
                            throws InvalidParameterException,
PropertyServerException,
UserNotAuthorizedException,
ConnectorCheckedException

Review all the volumes stored in UC.

Specified by:

refreshUnityCatalog in class OSSUnityCatalogInsideCatalogSyncBase

Parameters:

parentGUID - unique identifier of the parent

parentRelationshipTypeName - relationship type between parent and elements to iterate through

relationshipProperties - optional properties for the relationship

iterator - Metadata collection iterator

Throws:

InvalidParameterException - parameter error

PropertyServerException - repository error

UserNotAuthorizedException - security error

ConnectorCheckedException - logic error in properties