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

Class DataEngineEventProcessor

java.lang.Object
org.odpi.openmetadata.accessservices.dataengine.server.processors.DataEngineEventProcessor
public class DataEngineEventProcessor extends Object
The Data Engine event processor is processing events from external data engines about metadata changes. It will handle different types of events defined in Data Engine OMAS API module.

  • Constructor Details

    • DataEngineEventProcessor

      public DataEngineEventProcessor(DataEngineServicesInstance instance, AuditLog auditLog) throws NewInstanceException
      The constructor is given the connection to the out topic for Data Engine OMAS along with classes for testing and manipulating instances.
      Parameters:
      instance - server instance
      auditLog - audit log
      Throws:
      NewInstanceException - * @throws NewInstanceException a problem occurred during initialization

  • Method Details

    • processDataEngineRegistrationEvent

      public void processDataEngineRegistrationEvent(String dataEngineEvent)
      Process a DataEngineRegistrationEvent
      Parameters:
      dataEngineEvent - the event to be processed

    • processProcessHierarchyEvent

      public void processProcessHierarchyEvent(String dataEngineEvent)
      Process a ProcessHierarchyEvent
      Parameters:
      dataEngineEvent - the event to be processed

    • processPortImplementationEvent

      public void processPortImplementationEvent(String dataEngineEvent)
      Process a PortImplementationEvent
      Parameters:
      dataEngineEvent - the event to be processed

    • processDataFlowsEvent

      public void processDataFlowsEvent(String dataEngineEvent)
      Process a DataFlowsEvent
      Parameters:
      dataEngineEvent - the event to be processed

    • processProcessEvent

      public void processProcessEvent(String dataEngineEvent)
      Process a ProcessEvent
      Parameters:
      dataEngineEvent - the event to be processed

    • processSchemaTypeEvent

      public void processSchemaTypeEvent(String schemaTypeEvent)
      Process a SchemaTypeEvent
      Parameters:
      schemaTypeEvent - the event to be processed

    • processDeleteSchemaTypeEvent

      public void processDeleteSchemaTypeEvent(String dataEngineEvent)
      Process a DeleteEvent for deleting a schema type
      Parameters:
      dataEngineEvent - the event to be processed

    • processDeleteDataEngineEvent

      public void processDeleteDataEngineEvent(String dataEngineEvent)
      Process a DeleteEvent for deleting a data engine
      Parameters:
      dataEngineEvent - the event to be processed

    • processDeleteProcessEvent

      public void processDeleteProcessEvent(String dataEngineEvent)
      Process a DeleteEvent for deleting a process
      Parameters:
      dataEngineEvent - the event to be processed

    • processDeletePortImplementationEvent

      public void processDeletePortImplementationEvent(String dataEngineEvent)
      Process a DeleteEvent for deleting a port implementation
      Parameters:
      dataEngineEvent - the event to be processed

    • processDatabaseEvent

      public void processDatabaseEvent(String dataEngineEvent)
      Process a DatabaseEvent for creating a database
      Parameters:
      dataEngineEvent - the event to be processed

    • processDatabaseSchemaEvent

      public void processDatabaseSchemaEvent(String dataEngineEvent)
      Process a DatabaseSchemaEvent for creating a database schema
      Parameters:
      dataEngineEvent - the event to be processed

    • processRelationalTableEvent

      public void processRelationalTableEvent(String dataEngineEvent)
      Process a RelationalTableEvent for creating a relational table
      Parameters:
      dataEngineEvent - the event to be processed

    • processDataFileEvent

      public void processDataFileEvent(String dataEngineEvent)
      Process a DataFileEvent for creating a data file
      Parameters:
      dataEngineEvent - the event to be processed

    • processDeleteDatabaseEvent

      public void processDeleteDatabaseEvent(String dataEngineEvent)
      Process a DeleteEvent for deleting a database
      Parameters:
      dataEngineEvent - the event to be processed

    • processDeleteDatabaseSchemaEvent

      public void processDeleteDatabaseSchemaEvent(String dataEngineEvent)
      Process a DeleteEvent for deleting a database schema
      Parameters:
      dataEngineEvent - the event to be processed

    • processDeleteRelationalTableEvent

      public void processDeleteRelationalTableEvent(String dataEngineEvent)
      Process a DeleteEvent for deleting a relational table
      Parameters:
      dataEngineEvent - the event to be processed

    • processDeleteDataFileEvent

      public void processDeleteDataFileEvent(String dataEngineEvent)
      Process a DeleteEvent for deleting a data file
      Parameters:
      dataEngineEvent - the event to be processed

    • processDeleteFolderEvent

      public void processDeleteFolderEvent(String dataEngineEvent)
      Process a DeleteEvent for deleting a folder
      Parameters:
      dataEngineEvent - the event to be processed

    • processDeleteConnectionEvent

      public void processDeleteConnectionEvent(String dataEngineEvent)
      Process a DeleteEvent for deleting a connection
      Parameters:
      dataEngineEvent - the event to be processed

    • processDeleteEndpointEvent

      public void processDeleteEndpointEvent(String dataEngineEvent)
      Process a DeleteEvent for deleting an endpoint
      Parameters:
      dataEngineEvent - the event to be processed

    • processTopicEvent

      public void processTopicEvent(String dataEngineEvent)
      Process a TopicEvent for creating a topic
      Parameters:
      dataEngineEvent - the event to be processed

    • processEventTypeEvent

      public void processEventTypeEvent(String dataEngineEvent)
      Process a EventTypeEvent for creating a topic
      Parameters:
      dataEngineEvent - the event to be processed

    • processDeleteTopicEvent

      public void processDeleteTopicEvent(String dataEngineEvent)
      Process a DeleteEvent for deleting a topic
      Parameters:
      dataEngineEvent - the event to be processed

    • processDeleteEventTypeEvent

      public void processDeleteEventTypeEvent(String dataEngineEvent)
      Process a DeleteEvent for deleting an event type
      Parameters:
      dataEngineEvent - the event to be processed

    • processProcessingStateEvent

      public void processProcessingStateEvent(String dataEngineEvent)
      Process a ProcessingStateEvent for deleting an event type
      Parameters:
      dataEngineEvent - the event to be processed