Stream data processing system and stream data processing method
First Claim
1. A stream data processing system which executes a global query registered beforehand with respect to stream data and outputs an execution result thereof comprising:
- i-th (where, 1<
i<
n) query processing devices each of which executes i-th local query composing the global query; and
a proxy device which stores storage data including at least a part of the stream data, wherein the i-th query processing device includes;
a data receiving unit which receives the stream data in the case of i=1 and receives transfer data from the (i−
1)-th query processing device in the case of i≠
1;
a data registration unit which stores the storage data including at least a part of the received stream data in the proxy device in the case of 1<
i<
n;
a data obtaining unit which accesses the proxy device so as to obtain target data if the storage data includes the target data necessary for processing the i-th local query registered beforehand in the case of 1<
i<
n;
a local query processing unit which executes the i-th local query registered beforehand with respect to the stream data received by the data receiving unit in the case of i=1, and executes an i-th local query registered beforehand with respect to the transfer data received by the data receiving unit and/or the target data obtained by the data obtaining unit in the case of i≠
1; and
a data transmission unit which transmits a processing result of the local query processing unit, as the transfer data, to the (i+1)-th query processing device in the case of i≠
n, and transmits the processing result of the local query processing unit to a predetermined device in the case of i=n, and the proxy device includes;
a storage data storage unit which receives the storage data from the query processing device and stores the received storage data; and
a data reading unit that reads the target data requested from the query processing device from the storage data stored in the storage data storage unit and transmits the read target data to the query processing device which is a request source.
1 Assignment
0 Petitions
Accused Products
Abstract
A stream data processing system restrains the generation of communication traffic in the case of distributing loads by using a plurality of information processing devices. The global query is divided into a plurality of processes. At every divided process, a local query which includes the corresponding process is generated and each local query is set to a query processing device different from each other. In addition, the stream data is transmitted among a plurality of query processing devices in order so as to execute the local query in each query processing device. At this time, the entire stream data does not transmitted among the query processing devices in order. At least a part of the corresponding stream data is stored in a proxy device. When data received from an information processing device located in immediately before does not include the target data of the local query, the query processing device reads the corresponding data from the proxy device and executes the local query.
-
Citations
14 Claims
-
1. A stream data processing system which executes a global query registered beforehand with respect to stream data and outputs an execution result thereof comprising:
-
i-th (where, 1<
i<
n) query processing devices each of which executes i-th local query composing the global query; and
a proxy device which stores storage data including at least a part of the stream data, whereinthe i-th query processing device includes;
a data receiving unit which receives the stream data in the case of i=1 and receives transfer data from the (i−
1)-th query processing device in the case of i≠
1;
a data registration unit which stores the storage data including at least a part of the received stream data in the proxy device in the case of 1<
i<
n;
a data obtaining unit which accesses the proxy device so as to obtain target data if the storage data includes the target data necessary for processing the i-th local query registered beforehand in the case of 1<
i<
n;
a local query processing unit which executes the i-th local query registered beforehand with respect to the stream data received by the data receiving unit in the case of i=1, and executes an i-th local query registered beforehand with respect to the transfer data received by the data receiving unit and/or the target data obtained by the data obtaining unit in the case of i≠
1; and
a data transmission unit which transmits a processing result of the local query processing unit, as the transfer data, to the (i+1)-th query processing device in the case of i≠
n, and transmits the processing result of the local query processing unit to a predetermined device in the case of i=n, andthe proxy device includes;
a storage data storage unit which receives the storage data from the query processing device and stores the received storage data; and
a data reading unit that reads the target data requested from the query processing device from the storage data stored in the storage data storage unit and transmits the read target data to the query processing device which is a request source. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13)
-
-
14. A stream data processing method of causing a stream data processing system, which includes i-th (where, 1<
- i<
n) query processing devices each of which executes an i-th local query composing the global query and a proxy device which stores storage data including at least a part of the stream data, to perform;
executing a global query with respect to stream data; and
outputting an execution result thereof, wherein the i-th query processing device performs the steps of;
receiving the stream data in the case of i=1 and receiving transfer data from an (i−
1)-th query processing device in the case of i≠
1;
transmitting storage data including at least a part of the received stream data to the proxy device in the case of 1<
i<
n;
accessing the proxy device so as to obtain target data if the storage data includes the target data necessary for processing the i-th local query registered beforehand in the case of 1<
i<
n;
executing the i-th local query registered beforehand with respect to the received stream data in the case of i=1, or executing an i-th local query registered beforehand with respect to the received transfer data and the obtained target data in the case of i≠
1; and
transmitting an execution result of the local query, as transfer data, to an (i+1)-th query processing device in the case of i≠
n, and transmitting the execution result of the local query to a predetermined device in the case of i=n, andwherein the proxy device performs the steps of;
receiving the storage data from the query processing device and storing the received storage data; and
reading target data requested by the query processing device from the stored storage data and transmitting the read target data to the query processing device which is a request source.
- i<
Specification