This transport handler connects directly to the Odysseus system and allows to react on changes in the query plan.

The output of the operator is a tuple containing the following schema:

  • ts (STARTTIMESTAMP): The system time stamp in ms the query plan change occured
  • queryId (INTEGER): The id of the affected query
  • eventType (STRING): The type of event occured. This set is not final, e.g. the following events can occur: QUERY_ADDED, QUERY_REMOVE, QUERY_START, QUERY_STOP, QUERY_SUSPEND, QUERY_RESUME, QUERY_PARTIAL (see Query States for an explantion of the different states)
  • user (STRING): The name of the user that changed the query.

 

Example

#PARSER PQL
#RUNQUERY
planmodifications := ACCESS({
          source='PlanModificationWatcher',
          wrapper='GenericPush',
          transport='planmodificationwatcher',
          datahandler='Tuple'    
	})
  • No labels