| 摘要 |
To improve usability and a processing speed by waiting for a string of information associated with each other, and appropriately aggregating data satisfying a specific condition when outputting the data, and retaining and storing the aggregated data. In a case where a string of information originally associated with each other is arrival, separately, a data input/output unit determines a processing pattern on the basis of information on an input source. A data processing unit implements a processing condition for waiting for the associated information, individually, controls the storage of data in conformity with the processing condition, and aggregates and retains the string of data, and outputs an aggregation result. Also, the data processing unit can delete the string of unnecessary data in a lump. |
| 主权项 |
1. An input data aggregation processing apparatus, comprising:
a pattern determination table that stores a processing condition pattern number, for an input source in advance; a processing condition list that stores a start condition, an ending condition and an output destination, an intermediate condition for conducting aggregation processing at an intermediate point and the output destination, for the processing condition pattern number; an intermediate data table that stores a value to be aggregated and a completion flag, for a key value; and a processing unit, wherein the processing unit reads the respective divided input data in a case where a string of data having start and ending information separately arrives at the processing unit from an external system, the processing unit discriminates whether the input data is transmitted from any input source, the processing unit acquires a key value for identifying the string of data, a determination value in advancing processing, the value to be aggregated, and the processing condition pattern number, from the input data and the input source, with reference to the pattern determination table, the processing unit registers the key value and the value to be aggregated which are acquired from the input data, and the completion flag set to “not output” in the intermediate data table, and the processing unit conducts ending processing for calculating an aggregation result obtained by aggregating the values to be aggregated of one or a plurality of records of the same key value as the key value of the input data from the intermediate data table when the determination value satisfies the ending condition or the intermediate condition with reference to the processing condition list, completion flag edition processing for updating the completion flag of the one or the plurality of records as “already output”, and output processing for outputting the key value and the aggregation result to an output destination obtained with reference to the processing condition list. |
