| 摘要 |
PROBLEM TO BE SOLVED: To provide a system for easily implementing an aggregation process of processing, in combination with data that is already held, each piece of arriving data and then saving the result.SOLUTION: An aggregation processing system 1 includes: a data transmission unit 2 for transforming data which is a target of an aggregation process into a format of a tuple having a key and for transmitting it to a data processing unit 3; and the data processing unit 3 for performing the aggregation process of the transmitted tuple. When the tuple transmitted from the data transmission unit 2 is received, the data processing unit 3 invokes an operator and performs an aggregation process. In the aggregation process, aggregated data is generated based on the tuple received by the data processing unit 3 and a related input table, and writing to an output table or generation of an output tuple is performed based on the generated aggregated data. A plurality of aggregation processes are implemented by combining processes by the operators, and the plurality of aggregation processes are performed as one transaction. |
