| 摘要 |
Provided is a stream data processing device for processing stream data composed of input data that includes time, the device having: a data input module for receiving the input data; a first key for designating, as data sets, the items of the input data for processing the input data in chronological order; a query recorder for receiving a stream data definition and a query definition, and generating an operator to process the input data; and a data executing module for determining the operator for processing the input data and outputting results; the input module sorting the received input data for each of the data sets according to the item designated by the first key, sorting the input data in chronological order for each of the data sets, and generating an input stream; and the data executing module processing the input stream with the operator for each of the data sets.
|
