Interface DataEngineClient

    • Method Summary

      All Methods Instance Methods Abstract Methods 
      Modifier and Type Method Description
      void addLineageMappings​(java.lang.String userId, java.util.List<LineageMapping> lineageMappings)
      Add lineage mapping relationships between schema types
      java.lang.String addProcessHierarchy​(java.lang.String userId, ProcessHierarchy processHierarchy)
      Add a ProcessHierarchy relationship to a process
      java.lang.String createExternalDataEngine​(java.lang.String userId, SoftwareServerCapability softwareServerCapability)
      Create or update the software server capability entity
      java.lang.String createOrUpdatePortAlias​(java.lang.String userId, PortAlias portAlias, java.lang.String processQualifiedName)
      Create or update the port alias entity with a PortDelegation relationship.
      java.lang.String createOrUpdatePortImplementation​(java.lang.String userId, PortImplementation portImplementation, java.lang.String processQualifiedName)
      Create or update the port implementation entity,with the corresponding schema type and port schema relationship.
      java.lang.String createOrUpdateProcess​(java.lang.String userId, Process process)
      Create or update the process, with all the ports, schema types and corresponding relationships including the process hierarchy relationship.
      java.lang.String createOrUpdateSchemaType​(java.lang.String userId, SchemaType schemaType)
      Create or update the schema type entity, with the corresponding schema attributes and relationships
      void deleteConnection​(java.lang.String userId, java.lang.String qualifiedName, java.lang.String guid)
      Delete the connection
      void deleteDatabase​(java.lang.String userId, java.lang.String qualifiedName, java.lang.String guid)
      Delete the database
      void deleteDatabaseSchema​(java.lang.String userId, java.lang.String qualifiedName, java.lang.String guid)
      Delete the database schema
      void deleteDataFile​(java.lang.String userId, java.lang.String qualifiedName, java.lang.String guid)
      Delete the data file
      void deleteEndpoint​(java.lang.String userId, java.lang.String qualifiedName, java.lang.String guid)
      Delete the endpoint
      void deleteEventType​(java.lang.String userId, java.lang.String qualifiedName, java.lang.String guid)
      Delete the event type
      void deleteExternalDataEngine​(java.lang.String userId, java.lang.String qualifiedName, java.lang.String guid)
      Delete the external data engine
      void deleteFolder​(java.lang.String userId, java.lang.String qualifiedName, java.lang.String guid)
      Delete the folder
      void deletePortAlias​(java.lang.String userId, java.lang.String qualifiedName, java.lang.String guid)
      Delete the port alias
      void deletePortImplementation​(java.lang.String userId, java.lang.String qualifiedName, java.lang.String guid)
      Delete the port implementation
      void deleteProcess​(java.lang.String userId, java.lang.String qualifiedName, java.lang.String guid)
      Delete a process
      void deleteRelationalTable​(java.lang.String userId, java.lang.String qualifiedName, java.lang.String guid)
      Delete the relational table
      void deleteSchemaType​(java.lang.String userId, java.lang.String qualifiedName, java.lang.String guid)
      Delete the schema type
      void deleteTopic​(java.lang.String userId, java.lang.String qualifiedName, java.lang.String guid)
      Delete the topic
      GUIDListResponse find​(java.lang.String userId, FindRequestBody findRequestBody)
      Find an entity
      java.lang.String getExternalSourceName()
      Returns the name of the source system using data engine client
      void setExternalSourceName​(java.lang.String externalSourceName)
      Sets external source system name using the data engine client
      java.lang.String upsertDatabase​(java.lang.String userId, Database database)
      Create or update the database entity
      java.lang.String upsertDatabaseSchema​(java.lang.String userId, DatabaseSchema databaseSchema, java.lang.String databaseQualifiedName)
      Create or update the database schema entity
      java.lang.String upsertDataFile​(java.lang.String userId, DataFile dataFile)
      Create or update the data file entity
      java.lang.String upsertEventType​(java.lang.String userId, EventType eventType, java.lang.String topicQualifiedName)
      Create or update the event type entity
      java.lang.String upsertRelationalTable​(java.lang.String userId, RelationalTable relationalTable, java.lang.String databaseSchemaQualifiedName)
      Create or update the relational table entity
      java.lang.String upsertTopic​(java.lang.String userId, Topic topic)
      Create or update the topic entity