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

Class OSSUnityCatalogResourceConnector

java.lang.Object

org.odpi.openmetadata.frameworks.connectors.Connector

org.odpi.openmetadata.frameworks.connectors.ConnectorBase

org.odpi.openmetadata.adapters.connectors.unitycatalog.resource.OSSUnityCatalogResourceConnector

All Implemented Interfaces:

AuditLoggingComponent, SecureConnectorExtension, VirtualConnectorExtension

public class OSSUnityCatalogResourceConnector
extends ConnectorBase
implements AuditLoggingComponent

Nested Class Summary

Nested classes/interfaces inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

ConnectorBase.ProtectedConnection

Field Summary

Fields inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

connectedAssetProperties, connectionBean, connectionProperties, connectorInstanceId, embeddedConnectors, messageFormatter, secretsStoreConnectorMap

Constructor Summary

Constructors

Constructor	Description
OSSUnityCatalogResourceConnector()

Method Summary

Modifier and Type	Method	Description
CatalogInfo	createCatalog(String name, String comment, Map<String,String> properties)	Create catalog.
FunctionInfo	createFunction(FunctionProperties functionProperties)	Create function.
SchemaInfo	createSchema(String name, String catalogName, String comment, Map<String,String> properties)	Create schema.
TableInfo	createTable(String name, String catalogName, String schemaName, String comment, String tableType, String dataSourceFormat, List<ColumnInfo> columns, String storageLocation, Map<String,String> properties)	Create table.
TableInfo	createTable(TableProperties tableProperties)	Create table.
VolumeInfo	createVolume(String name, String catalogName, String schemaName, String comment, String volumeType, String storageLocation)	Create volume.
VolumeInfo	createVolume(VolumeProperties volumeProperties)	Create volume.
void	deleteCatalog(String name, boolean force)	Delete catalog.
void	deleteFunction(String fullName)	Delete function.
void	deleteSchema(String fullName, boolean force)	Delete schema.
void	deleteTable(String fullName)	Delete table.
void	deleteVolume(String fullName)	Delete volume.
CatalogInfo	getCatalog(String name)	Get catalog.
String	getCatalogNameFromThreePartName(String threePartName)	The catalog name is in the first segment of the three part name.
ComponentDescription	getConnectorComponentDescription()	Return the component description that is used by this connector in the audit log.
FunctionInfo	getFunction(String fullName)	Get function.
String	getNameFromFullName(String fullName)	The full name uses dot separators.
SchemaInfo	getSchema(String fullName)	Get schema.
String	getSchemaNameFromThreePartName(String threePartName)	The schema name is in the middle segment of the three part name.
TableInfo	getTable(String fullName)	Get table.
VolumeInfo	getVolume(String fullName)	Get volume.
List<CatalogInfo>	listCatalogs()	Get all catalog.
List<FunctionInfo>	listFunctions(String catalogName, String schemaName)	Get all functions.
List<SchemaInfo>	listSchemas(String catalogName)	Get all schema.
List<TableInfo>	listTables(String catalogName, String schemaName)	Get all tables.
List<VolumeInfo>	listVolumes(String catalogName, String schemaName)	Get all volumes.
void	setAuditLog(AuditLog auditLog)	Receive an audit log object that can be used to record audit log messages.
void	setUCInstanceName(String ucInstanceName)	Set up a new instance name (must be called before start()).
void	start()	Indicates that the connector is completely configured and can begin processing.
CatalogInfo	updateCatalog(String name, String newName, String comment, Map<String,String> properties)	Update catalog.
SchemaInfo	updateSchema(String fullName, String newName, String comment, Map<String,String> properties)	Update schema.
VolumeInfo	updateVolume(String fullName, String newName, String comment)	Update volume.

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.ConnectorBase

combineConfigurationProperties, disconnect, disconnectConnectors, equals, getArrayConfigurationProperty, getAssetTypeName, getBooleanConfigurationProperty, getConnectedAssetProperties, getConnection, getConnectorInstanceId, getIntConfigurationProperty, getLongConfigurationProperty, getNetworkAddresses, getStringConfigurationProperty, getSuppliedPlaceholderProperties, hashCode, initialize, initializeConnectedAssetProperties, initializeEmbeddedConnectors, initializeSecretsStoreConnector, isActive, logExceptionRecord, logRecord, logRecord, throwMissingConfigurationProperty, throwMissingResource, throwNoAsset, throwWrongTypeOfAsset, throwWrongTypeOfResource, throwWrongTypeOfRootSchema, toString

Methods inherited from class org.odpi.openmetadata.frameworks.connectors.Connector

clearStatisticProperty, clearStatisticTimestamp, getConnectorStatistics, getStatisticCounter, getStatisticProperty, getStatisticTimestamp, incrementStatisticCounter, initializeStatisticCounter, setStatisticProperty, setStatisticTimestamp

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

OSSUnityCatalogResourceConnector

public OSSUnityCatalogResourceConnector()

Method Details

setAuditLog

public void setAuditLog(AuditLog auditLog)

Receive an audit log object that can be used to record audit log messages. The caller has initialized it with the correct component description and log destinations.

Specified by:

setAuditLog in interface AuditLoggingComponent

Parameters:

auditLog - audit log object

getConnectorComponentDescription

public ComponentDescription getConnectorComponentDescription()

Return the component description that is used by this connector in the audit log.

Specified by:

getConnectorComponentDescription in interface AuditLoggingComponent

Returns:

id, name, description, wiki page URL.

setUCInstanceName

public void setUCInstanceName(String ucInstanceName)

Set up a new instance name (must be called before start()).

Parameters:

ucInstanceName - new instance name

start

public void start()
           throws ConnectorCheckedException

Indicates that the connector is completely configured and can begin processing. This call can be used to register with non-blocking services.

Overrides:

start in class ConnectorBase

Throws:

ConnectorCheckedException - there is a problem within the connector.

getNameFromFullName

public String getNameFromFullName(String fullName)

The full name uses dot separators. Return the name after the final dot.

Parameters:

fullName - dotted name

Returns:

short name

getSchemaNameFromThreePartName

public String getSchemaNameFromThreePartName(String threePartName)

The schema name is in the middle segment of the three part name.

Parameters:

threePartName - dotted name

Returns:

schemaName

getCatalogNameFromThreePartName

public String getCatalogNameFromThreePartName(String threePartName)

The catalog name is in the first segment of the three part name.

Parameters:

threePartName - dotted name

Returns:

catalogName

createCatalog

public CatalogInfo createCatalog(String name,
 String comment,
 Map<String,String> properties)
                          throws PropertyServerException

Create catalog.

Parameters:

name - name of the catalog

comment - description of the catalog

properties - additional properties

Returns:

resulting catalog info

Throws:

PropertyServerException - problem with the call

deleteCatalog

public void deleteCatalog(String name,
 boolean force)
                   throws PropertyServerException

Delete catalog.

Parameters:

name - name of the catalog

force - force the deletion

Throws:

PropertyServerException - problem with the call

getCatalog

public CatalogInfo getCatalog(String name)
                       throws PropertyServerException

Get catalog.

Parameters:

name - name of the catalog

Returns:

resulting catalog info

Throws:

PropertyServerException - problem with the call

listCatalogs

public List<CatalogInfo> listCatalogs()
                               throws PropertyServerException

Get all catalog.

Returns:

resulting catalog info

Throws:

PropertyServerException - problem with the call

updateCatalog

public CatalogInfo updateCatalog(String name,
 String newName,
 String comment,
 Map<String,String> properties)
                          throws PropertyServerException

Update catalog. This call overrides all existing properties.

Parameters:

name - name of the catalog

newName - optional new name of the catalog

comment - description of the catalog

properties - additional properties

Returns:

resulting catalog info

Throws:

PropertyServerException - problem with the call

createSchema

public SchemaInfo createSchema(String name,
 String catalogName,
 String comment,
 Map<String,String> properties)
                        throws PropertyServerException

Create schema.

Parameters:

name - name of the schema

catalogName - name of catalog

comment - description of the schema

properties - additional properties

Returns:

resulting schema info

Throws:

PropertyServerException - problem with the call

deleteSchema

public void deleteSchema(String fullName,
 boolean force)
                  throws PropertyServerException

Delete schema.

Parameters:

fullName - fullName of the schema

force - force the deletion

Throws:

PropertyServerException - problem with the call

getSchema

public SchemaInfo getSchema(String fullName)
                     throws PropertyServerException

Get schema.

Parameters:

fullName - fullName of the schema

Returns:

resulting schema info

Throws:

PropertyServerException - problem with the call

listSchemas

public List<SchemaInfo> listSchemas(String catalogName)
                             throws PropertyServerException

Get all schema.

Returns:

resulting schema info

Throws:

PropertyServerException - problem with the call

updateSchema

public SchemaInfo updateSchema(String fullName,
 String newName,
 String comment,
 Map<String,String> properties)
                        throws PropertyServerException

Update schema.

Parameters:

fullName - name of the schema

newName - optional new name of the schema

comment - description of the schema

properties - additional properties

Returns:

resulting schema info

Throws:

PropertyServerException - problem with the call

createVolume

public VolumeInfo createVolume(String name,
 String catalogName,
 String schemaName,
 String comment,
 String volumeType,
 String storageLocation)
                        throws PropertyServerException

Create volume.

Parameters:

name - name of the volume

catalogName - name of catalog

schemaName - name of the schema

comment - description of the volume

volumeType - MANAGED, or EXTERNAL

storageLocation - directory name eg file:///Users/me/Code/uc/unitycatalog/etc/data/external/unity/default/volumes/json_files/

Returns:

resulting volume info

Throws:

PropertyServerException - problem with the call

createVolume

public VolumeInfo createVolume(VolumeProperties volumeProperties)
                        throws PropertyServerException

Create volume.

Parameters:

volumeProperties - properties

Returns:

resulting volume info

Throws:

PropertyServerException - problem with the call

deleteVolume

public void deleteVolume(String fullName)
                  throws PropertyServerException

Delete volume.

Parameters:

fullName - fullName of the volume

Throws:

PropertyServerException - problem with the call

getVolume

public VolumeInfo getVolume(String fullName)
                     throws PropertyServerException

Get volume.

Parameters:

fullName - fullName of the volume

Returns:

resulting volume info

Throws:

PropertyServerException - problem with the call

listVolumes

public List<VolumeInfo> listVolumes(String catalogName,
 String schemaName)
                             throws PropertyServerException

Get all volumes.

Parameters:

catalogName - name of the catalog

schemaName - name of the schema

Returns:

resulting volume info

Throws:

PropertyServerException - problem with the call

updateVolume

public VolumeInfo updateVolume(String fullName,
 String newName,
 String comment)
                        throws PropertyServerException

Update volume.

Parameters:

fullName - name of the volume

newName - optional new name of the volume

comment - description of the volume

Returns:

resulting volume info

Throws:

PropertyServerException - problem with the call

createTable

public TableInfo createTable(String name,
 String catalogName,
 String schemaName,
 String comment,
 String tableType,
 String dataSourceFormat,
 List<ColumnInfo> columns,
 String storageLocation,
 Map<String,String> properties)
                      throws PropertyServerException

Create table.

Parameters:

name - name of the table

catalogName - name of catalog

schemaName - name of the schema

comment - description of the table

tableType - MANAGED, or EXTERNAL

dataSourceFormat - format

columns - list of columns in the table

storageLocation - directory name eg file:///Users/me/Code/uc/unitycatalog/etc/data/external/unity/default/tables/json_files/

Returns:

resulting table info

Throws:

PropertyServerException - problem with the call

createTable

public TableInfo createTable(TableProperties tableProperties)
                      throws PropertyServerException

Create table.

Parameters:

tableProperties - list of properties for the table

Returns:

resulting table info

Throws:

PropertyServerException - problem with the call

deleteTable

public void deleteTable(String fullName)
                 throws PropertyServerException

Delete table.

Parameters:

fullName - fullName of the table

Throws:

PropertyServerException - problem with the call

getTable

public TableInfo getTable(String fullName)
                   throws PropertyServerException

Get table.

Parameters:

fullName - fullName of the table

Returns:

resulting table info

Throws:

PropertyServerException - problem with the call

listTables

public List<TableInfo> listTables(String catalogName,
 String schemaName)
                           throws PropertyServerException

Get all tables.

Parameters:

catalogName - name of the catalog

schemaName - name of the schema

Returns:

resulting table info

Throws:

PropertyServerException - problem with the call

createFunction

public FunctionInfo createFunction(FunctionProperties functionProperties)
                            throws PropertyServerException

Create function.

Parameters:

functionProperties - list of properties for the function

Returns:

resulting function info

Throws:

PropertyServerException - problem with the call

deleteFunction

public void deleteFunction(String fullName)
                    throws PropertyServerException

Delete function.

Parameters:

fullName - fullName of the function

Throws:

PropertyServerException - problem with the call

getFunction

public FunctionInfo getFunction(String fullName)
                         throws PropertyServerException

Get function.

Parameters:

fullName - fullName of the function

Returns:

resulting function info

Throws:

PropertyServerException - problem with the call

listFunctions

public List<FunctionInfo> listFunctions(String catalogName,
 String schemaName)
                                 throws PropertyServerException

Get all functions.

Parameters:

catalogName - name of the catalog

schemaName - name of the schema

Returns:

resulting function info

Throws:

PropertyServerException - problem with the call