STREAM DATA PROCESSING METHOD WITH TIME ADJUSTMENT

摘要

Some stream data (e.g., sensor streams) has characteristics in which data is periodically sent to a stream data processing server. When data arrives periodically, to hold a certain period is the same as to hold a certain amount. Example implementations described herein are directed to replacing the range window, which holds a period of stream data, with a row window which holds an amount of stream data. In the same manner, the example implementations replace the range rstream, which outputs results every period, with a row rstream which outputs results for every amount.

主权项

1. A non-transitory computer readable medium containing instructions for executing a process, the instructions comprising:
determining one or more stream data interval definitions from stream data interval information; generating an input interval check module configured to detect periodic arrival of stream data based on the one or more stream data interval definitions; for each of the one or more stream data interval definitions, configuring a query execution module by:
determining one or more range window operators of the query execution module associated with the each of the one or more stream data interval definitions;modifying the determined one or more range window operators into one of a row based sliding window operator and a time based sliding window operator; andadjusting a row window size of the query execution module.