Package org.odpi.openmetadata.accessservices.dataengine.server.handlers

Class DataEnginePortHandler

java.lang.Object

org.odpi.openmetadata.accessservices.dataengine.server.handlers.DataEnginePortHandler

public class DataEnginePortHandler
extends Object

PortHandler manages Port objects from the property server. It runs server-side in the DataEngine OMAS and creates port entities with wire relationships through the OMRSRepositoryConnector.

Constructor Summary

Constructors

Constructor	Description
DataEnginePortHandler(String serviceName, String serverName, InvalidParameterHandler invalidParameterHandler, OMRSRepositoryHelper repositoryHelper, DataEngineCommonHandler dataEngineCommonHandler, PortHandler<Port> portHandler, DataEngineRegistrationHandler registrationHandler)	Construct the handler information needed to interact with the repository services

Method Summary

Modifier and Type	Method	Description
void	addPortSchemaRelationship(String userId, String portGUID, String schemaTypeGUID, String externalSourceName)	Create a PortSchema relationship between a Port and the corresponding SchemaType.
String	createPortImplementation(String userId, PortImplementation port, String processGUID, String externalSourceName)	Create the port implementation attached to a process.
Optional<EntityDetail>	findPortImplementationEntity(String userId, String qualifiedName)	Find out if the PortImplementation object is already stored in the repository.
Optional<EntityDetail>	findSchemaTypeForPort(String userId, String portGUID)	Retrieve the schema type that is linked to the port
void	removePort(String userId, String portGUID, String externalSourceName, DeleteSemantic deleteSemantic)	Remove the port
void	updatePortImplementation(String userId, EntityDetail originalPortEntity, PortImplementation port, String externalSourceName)	Update the port implementation

Methods inherited from class java.lang.Object

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

Constructor Details

DataEnginePortHandler

public DataEnginePortHandler(String serviceName,
 String serverName,
 InvalidParameterHandler invalidParameterHandler,
 OMRSRepositoryHelper repositoryHelper,
 DataEngineCommonHandler dataEngineCommonHandler,
 PortHandler<Port> portHandler,
 DataEngineRegistrationHandler registrationHandler)

Construct the handler information needed to interact with the repository services

Parameters:

serviceName - name of this service

serverName - name of the local server

invalidParameterHandler - handler for managing parameter errors

repositoryHelper - provides utilities for manipulating the repository services objects

dataEngineCommonHandler - provides utilities for manipulating entities

portHandler - provides utilities for manipulating the repository services ports

registrationHandler - provides utilities for manipulating engine entities

Method Details

createPortImplementation

public String createPortImplementation(String userId,
 PortImplementation port,
 String processGUID,
 String externalSourceName)
                                throws InvalidParameterException,
UserNotAuthorizedException,
PropertyServerException

Create the port implementation attached to a process.

Parameters:

userId - the name of the calling user

port - the port implementation values

processGUID - the unique identifier of the process

externalSourceName - the unique name of the external source

Returns:

unique identifier of the port implementation in the repository

Throws:

InvalidParameterException - the bean properties are invalid

UserNotAuthorizedException - user not authorized to issue this request

PropertyServerException - problem accessing the property server

updatePortImplementation

public void updatePortImplementation(String userId,
 EntityDetail originalPortEntity,
 PortImplementation port,
 String externalSourceName)
                              throws InvalidParameterException,
UserNotAuthorizedException,
PropertyServerException

Update the port implementation

Parameters:

userId - the name of the calling user

originalPortEntity - the created port entity

port - the port implementation new values

externalSourceName - the external data engine

Throws:

InvalidParameterException - the bean properties are invalid

UserNotAuthorizedException - user not authorized to issue this request

PropertyServerException - problem accessing the property server

addPortSchemaRelationship

public void addPortSchemaRelationship(String userId,
 String portGUID,
 String schemaTypeGUID,
 String externalSourceName)
                               throws InvalidParameterException,
UserNotAuthorizedException,
PropertyServerException

Create a PortSchema relationship between a Port and the corresponding SchemaType. Verifies that the relationship is not present before creating it

Parameters:

userId - the name of the calling user

portGUID - the unique identifier of the port

schemaTypeGUID - the unique identifier of the schema type

externalSourceName - the unique name of the external source

Throws:

InvalidParameterException - the bean properties are invalid

UserNotAuthorizedException - user not authorized to issue this request

PropertyServerException - problem accessing the property server

findSchemaTypeForPort

public Optional<EntityDetail> findSchemaTypeForPort(String userId,
 String portGUID)
                                             throws InvalidParameterException,
UserNotAuthorizedException,
PropertyServerException

Retrieve the schema type that is linked to the port

Parameters:

userId - the name of the calling user

portGUID - the unique identifier of the port

Returns:

retrieved entity or an empty optional

Throws:

InvalidParameterException - the bean properties are invalid

UserNotAuthorizedException - user not authorized to issue this request

PropertyServerException - problem accessing the property server

removePort

public void removePort(String userId,
 String portGUID,
 String externalSourceName,
 DeleteSemantic deleteSemantic)
                throws InvalidParameterException,
PropertyServerException,
UserNotAuthorizedException,
FunctionNotSupportedException

Remove the port

Parameters:

userId - the name of the calling user

portGUID - unique identifier of the port to be removed

externalSourceName - the external data engine

deleteSemantic - the delete semantic

Throws:

InvalidParameterException - the bean properties are invalid

UserNotAuthorizedException - user not authorized to issue this request

PropertyServerException - problem accessing the property server

FunctionNotSupportedException - the repository does not support this call.

findPortImplementationEntity

public Optional<EntityDetail> findPortImplementationEntity(String userId,
 String qualifiedName)
                                                    throws InvalidParameterException,
UserNotAuthorizedException,
PropertyServerException

Find out if the PortImplementation object is already stored in the repository. It uses the fully qualified name to retrieve the entity

Parameters:

userId - the name of the calling user

qualifiedName - the qualifiedName name of the process to be searched

Returns:

optional with entity details if found, empty optional if not found

Throws:

InvalidParameterException - the bean properties are invalid

UserNotAuthorizedException - user not authorized to issue this request

PropertyServerException - problem accessing the property server