Machine-readable medium for storing a stream data processing program and computer system
First Claim
1. A machine-readable medium for storing a stream data processing program for receiving, as primary information, stream data input to a computer comprising a processor and a storage system, creating secondary information by obtaining a given period of the received primary information as a processing target, and generating time control information indicating advance of time in addition to the primary information,wherein the stream data processing program controls the computer to execute the procedures of:
- receiving the input stream data as the primary information;
calculating, by a time control information generation module for generating, as the time control information, time information at a time of reception of the primary information, a time at which the time control information is generated as a next ignition time, and storing the next ignition time in a next ignition time holding area, which is set in the storage system;
generating the time control information when current time information reaches the next ignition time held in the next ignition time holding area; and
creating, upon reception of the generated time control information, secondary information by obtaining the given period of the received primary information as the processing target.
1 Assignment
0 Petitions
Accused Products
Abstract
In a stream data processing method in which part of stream data is defined as a processing target and the time control information which indicates the advance of the time is inserted into the stream data, time information of the received stream data is stored in a next ignition time holding area as an ignition time. A processing module for generating the time control information at a time different from the time of reception of the stream data is extracted out of a query that indicates how the stream data is to be processed. Based on the extracted processing module and the time information indicating the time of the reception of the stream data, the ignition time is calculated and stored in the next ignition time holding area. The time generation module inserts the time control information at the ignition time held in the next ignition time holding area.
-
Citations
13 Claims
-
1. A machine-readable medium for storing a stream data processing program for receiving, as primary information, stream data input to a computer comprising a processor and a storage system, creating secondary information by obtaining a given period of the received primary information as a processing target, and generating time control information indicating advance of time in addition to the primary information,
wherein the stream data processing program controls the computer to execute the procedures of: -
receiving the input stream data as the primary information; calculating, by a time control information generation module for generating, as the time control information, time information at a time of reception of the primary information, a time at which the time control information is generated as a next ignition time, and storing the next ignition time in a next ignition time holding area, which is set in the storage system; generating the time control information when current time information reaches the next ignition time held in the next ignition time holding area; and creating, upon reception of the generated time control information, secondary information by obtaining the given period of the received primary information as the processing target. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11)
-
-
12. A computer system, comprising:
-
a processor; a storage system; and an interface, the computer system obtaining, as primary information, stream data which is set in the storage system and input via the interface, creating secondary information by obtaining a given period of the obtained primary information, and generating time control information indicating advance of time in addition to the primary information, the computer system further comprising; a query execution tree analyzing module for extracting from a query a processing module that needs to generate the time control information at a time different from a time of reception of the primary information, the query indicating processing specifics for creating the secondary information by obtaining the primary information; a next ignition time calculating module for calculating an ignition time from based on extracted processing module and based on time information at the time of the reception of the primary information, and storing the ignition time in a next ignition time holding area, which is set in the storage system, the ignition time being a time at which a time control information generation module for generating the time control information generates the time control information; and a time control information generation module for generating, as the time control information, the time information at the time of the reception of the primary information, wherein the time control information generation module generates the time control information when current time information reaches the ignition time held in the next ignition time holding area.
-
-
13. A computer system, comprising:
-
a first computer; and a second computer, the first computer generating stream data, which is received as primary information, attaching time information that is generated in the first computer to the primary information, and transmitting the primary information to the second computer, the second computer creating secondary information by obtaining a given period of the received primary information, the first computer transmitting time control information indicating advance of time to the second computer in addition to the primary information, the computer system further comprising; a query execution tree analyzing module of the second computer, for extracting from a query a processing module that needs to generate the time control information at a time different from a time of reception of the primary information, the query indicating processing specifics for creating the secondary information by obtaining the primary information; a next ignition time calculating module of the second computer, for calculating an ignition time based on the extracted processing module and based on time information at the time of the reception of the primary information, and transmitting the ignition time to the first computer, the ignition time being a time at which a time control information generation module for generating the time control information generates the time control information; a next ignition time message receiving module of the first computer, for receiving the ignition time and storing the received ignition time in a next ignition time holding area, where the ignition time is held; and a time control information generation module of the first computer, for transmitting the time control information to the second computer at the ignition time held in the next ignition time holding area.
-
Specification