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

Class OSSUnityCatalogServerSyncCatalog

java.lang.Object

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

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

public class OSSUnityCatalogServerSyncCatalog
extends OSSUnityCatalogInsideCatalogSyncBase

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

Field Summary

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

auditLog, catalogGUID, catalogName, catalogQualifiedName, configurationProperties, connectorName, context, deployedImplementationType, excludeNames, includeNames, openMetadataAccess, propertyHelper, targetPermittedSynchronization, templates, ucConnector, ucFullNameToEgeriaGUID, ucServerEndpoint

Constructor Summary

Constructors

Constructor

Description

OSSUnityCatalogServerSyncCatalog(String connectorName, CatalogIntegratorContext context, String catalogTargetName, String ucServerGUID, String friendshipConnectorGUID, PermittedSynchronization targetPermittedSynchronization, OSSUnityCatalogResourceConnector ucConnector, String ucServerEndpoint, Map<String,String> templates, Map<String,Object> configurationProperties, List<String> excludeCatalogs, List<String> includeCatalogs, AuditLog auditLog)

Set up the catalog synchronizer.

Method Summary

Modifier and Type	Method	Description
protected IntegrationIterator	refreshEgeria()	Review all the catalogs stored in Egeria.
protected void	refreshUnityCatalog(IntegrationIterator iterator)	Review all the catalogs stored in UC.
protected void	updateElementInEgeria(CatalogInfo catalogInfo, MemberElement memberElement)	Update an element in open metadata.

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

addPropertyFacet, deleteElementInEgeria, getDateFromLong, getExternalIdentifierProperties, getPathNameFromStorageLocation, getQualifiedName, getUCCatalogFromMember, getUCCommentFomMember, getUCNameFromMember, getUCPropertiesFromMember, getUCSchemaFromMember, getUCStorageLocationFromMember, noMismatchInExternalIdentifier

Methods inherited from class java.lang.Object

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

Constructor Details

OSSUnityCatalogServerSyncCatalog

public OSSUnityCatalogServerSyncCatalog(String connectorName,
 CatalogIntegratorContext context,
 String catalogTargetName,
 String ucServerGUID,
 String friendshipConnectorGUID,
 PermittedSynchronization targetPermittedSynchronization,
 OSSUnityCatalogResourceConnector ucConnector,
 String ucServerEndpoint,
 Map<String,String> templates,
 Map<String,Object> configurationProperties,
 List<String> excludeCatalogs,
 List<String> includeCatalogs,
 AuditLog auditLog)

Set up the catalog synchronizer.

Parameters:

connectorName - name of this connector

context - context for the connector

catalogTargetName - the catalog target name

ucServerGUID - unique identifier of the UC Server

friendshipConnectorGUID - optional unique name of inside catalog integration connector

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

excludeCatalogs - list of catalogs to ignore (and include all others)

includeCatalogs - list of catalogs to include (and ignore all others) - overrides excludeCatalogs

auditLog - logging destination

Method Details

refreshEgeria

protected IntegrationIterator refreshEgeria()
                                     throws InvalidParameterException,
PropertyServerException,
UserNotAuthorizedException

Review all the catalogs stored in Egeria.

Specified by:

refreshEgeria in class OSSUnityCatalogInsideCatalogSyncBase

Returns:

MetadataCollectionIterator

Throws:

InvalidParameterException - parameter error

PropertyServerException - repository error

UserNotAuthorizedException - security error

refreshUnityCatalog

protected void refreshUnityCatalog(IntegrationIterator iterator)
                            throws InvalidParameterException,
PropertyServerException,
UserNotAuthorizedException

Review all the catalogs stored in UC.

Specified by:

refreshUnityCatalog in class OSSUnityCatalogInsideCatalogSyncBase

Parameters:

iterator - Metadata collection iterator

Throws:

InvalidParameterException - parameter error

PropertyServerException - repository error

UserNotAuthorizedException - security error

updateElementInEgeria

protected void updateElementInEgeria(CatalogInfo catalogInfo,
 MemberElement memberElement)
                              throws InvalidParameterException,
PropertyServerException,
UserNotAuthorizedException

Update an element in open metadata.

Parameters:

catalogInfo - object from UC

memberElement - existing element in egeria

Throws:

InvalidParameterException - parameter error

PropertyServerException - repository error

UserNotAuthorizedException - authorization error