| 主权项 |
1. A method comprising:
receiving a data stream of continuous data; setting up an event pipe in which is stored a sliding window of events from the data stream using a sliding window function having a parameter, wherein each event of the sliding window of events is stored within the event pipe as a tuple that maps attributes to values, and wherein old events within the event pipe are moved out of the event pipe as new events arrive, the sliding window function buffering and continuously maintaining events within the sliding window of events from the data stream; in response to the parameter of the sliding window function being set to a first value, responding, by the sliding window function, to an information request by returning the sliding window of events stored in the event pipe; emptying the event pipe whenever the sliding window of events stored in the pipeline has been utilized; and in response to the parameter of the sliding window function being set to a second value, returning, by the sliding window function, a null value, while the sliding window function still buffers and continuously maintains events within the sliding window of events from the data stream, the null value being returned even though new events are being received from the data stream. |
