Class OSSUnityCatalogServerSyncCatalog
java.lang.Object
org.odpi.openmetadata.adapters.connectors.unitycatalog.sync.OSSUnityCatalogInsideCatalogSyncBase
org.odpi.openmetadata.adapters.connectors.unitycatalog.sync.OSSUnityCatalogServerSyncCatalog
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, catalogName, catalogTargetName, configurationProperties, connectorName, context, deployedImplementationType, excludeNames, includeNames, openMetadataAccess, propertyHelper, targetPermittedSynchronization, templates, ucConnector, ucFullNameToEgeriaGUID, ucServerEndpoint
-
Constructor Summary
ConstructorsConstructorDescriptionOSSUnityCatalogServerSyncCatalog
(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 TypeMethodDescriptionprotected IntegrationIterator
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, getUCCatalogFomMember, getUCCommentFomMember, getUCNameFromMember, getUCPropertiesFomMember, getUCSchemaFomMember, getUCStorageLocationFromMember, noMismatchInExternalIdentifier
-
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 connectorcontext
- context for the connectorcatalogTargetName
- the catalog target nameucServerGUID
- unique identifier of the UC ServerfriendshipConnectorGUID
- optional unique name of inside catalog integration connectortargetPermittedSynchronization
- the policy that controls the direction of metadata exchangeucConnector
- connector for accessing UCucServerEndpoint
- the server endpoint used to constructing the qualified namestemplates
- templates supplied through the catalog targetconfigurationProperties
- configuration properties supplied through the catalog targetexcludeCatalogs
- list of catalogs to ignore (and include all others)includeCatalogs
- list of catalogs to include (and ignore all others) - overrides excludeCatalogsauditLog
- logging destination
-
-
Method Details
-
refreshEgeria
protected IntegrationIterator refreshEgeria() throws InvalidParameterException, PropertyServerException, UserNotAuthorizedExceptionReview all the catalogs stored in Egeria.- Specified by:
refreshEgeria
in classOSSUnityCatalogInsideCatalogSyncBase
- Returns:
- MetadataCollectionIterator
- Throws:
InvalidParameterException
- parameter errorPropertyServerException
- repository errorUserNotAuthorizedException
- security error
-
refreshUnityCatalog
protected void refreshUnityCatalog(IntegrationIterator iterator) throws InvalidParameterException, PropertyServerException, UserNotAuthorizedException Review all the catalogs stored in UC.- Specified by:
refreshUnityCatalog
in classOSSUnityCatalogInsideCatalogSyncBase
- Parameters:
iterator
- Metadata collection iterator- Throws:
InvalidParameterException
- parameter errorPropertyServerException
- repository errorUserNotAuthorizedException
- security error
-
updateElementInEgeria
protected void updateElementInEgeria(CatalogInfo catalogInfo, MemberElement memberElement) throws InvalidParameterException, PropertyServerException, UserNotAuthorizedException Update an element in open metadata.- Parameters:
catalogInfo
- object from UCmemberElement
- existing element in egeria- Throws:
InvalidParameterException
- parameter errorPropertyServerException
- repository errorUserNotAuthorizedException
- authorization error
-