Stream data processing control method, stream data processing apparatus, and stream data processing control program

A stream data processing apparatus for receiving data added with time information in time series, and processing the data with a registered query therein, the stream data processing apparatus comprising:

• an interface for receiving the data;
• a processor coupled to the interface;
• and
• a memory device coupled to the processor, for storing therein the query for processing the data, a window in which the received data is stored in a case where the received data is processed by the query, and control management information including a content of the controlling of the stream data processing apparatus and a control code for identifying the content of the controlling,
• wherein the processor is configured to:
• create data including the control code based on the control management information in a case where the stream data processing apparatus receives the data;
• determine whether or not the data stored in the window includes the control code in a case where the received data is stored in the window;
• and
• control the stream data processing apparatus based on the control code included in the data in a case where the data stored in the window includes the control code.

A storage medium recorded with a stream data processing control program executed by a stream data processing apparatus for receiving data added with time information in time series, and processing the data with a registered query therein,

• the stream data processing apparatus storing therein control management information including a content of control over the stream data processing apparatus and a control code corresponding to the content of the control,
• the stream data processing control program including the steps of:
• creating a window in which the data is stored in a case where the data is processed by the query;
• creating data including the control code based on the control management information in a case where the data is received;
• determining whether or not the data stored in the window includes the control code;
• and
• controlling the stream data processing apparatus based on the control code included in the data stored in the window in a case where the data stored in the window includes the control code.