STREAM DATA PROCESSING METHOD AND DEVICE

摘要

Provided is a stream data processing device for processing stream data composed of input data that includes time, the device having: a data input part for receiving the input data that constitutes the stream 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 definition of the stream data and a query definition, and generating an operator to process the input data; and a data executing part for determining the operator for processing the input data for each of the data sets and outputting results obtained by processing the input data with the operator; the input part 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 part processing the input stream with the operator for each of the data sets.