Class OSSUnityCatalogInsideCatalogSyncFunctions
java.lang.Object
org.odpi.openmetadata.adapters.connectors.unitycatalog.sync.OSSUnityCatalogInsideCatalogSyncBase
org.odpi.openmetadata.adapters.connectors.unitycatalog.sync.OSSUnityCatalogInsideCatalogSyncFunctions
Provides the specialist methods for working with Unity Catalog (UC) Functions.
-
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
ConstructorsConstructorDescriptionOSSUnityCatalogInsideCatalogSyncFunctions
(String connectorName, CatalogIntegratorContext context, String catalogTargetName, 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 function synchronizer. -
Method Summary
Modifier and TypeMethodDescriptionprotected IntegrationIterator
Review all the functions stored in Egeria.protected void
refreshUnityCatalog
(IntegrationIterator iterator) Review all the functions stored in UC.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
-
OSSUnityCatalogInsideCatalogSyncFunctions
public OSSUnityCatalogInsideCatalogSyncFunctions(String connectorName, CatalogIntegratorContext context, String catalogTargetName, 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 function synchronizer.- Parameters:
connectorName
- name of this connectorcontext
- context for the connectorcatalogTargetName
- the catalog target namecatalogName
- name of the catalogucFullNameToEgeriaGUID
- map of full names from UC to the GUID of the entity in Egeria.targetPermittedSynchronization
- 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 targetexcludeNames
- list of catalogs to ignore (and include all others)includeNames
- 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 functions 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 functions stored in UC.- Specified by:
refreshUnityCatalog
in classOSSUnityCatalogInsideCatalogSyncBase
- Parameters:
iterator
- Metadata collection iterator- Throws:
InvalidParameterException
- parameter errorPropertyServerException
- repository errorUserNotAuthorizedException
- security error
-