TIME-BASED WINDOW EXPERIMENT 1

Time-based Window Experiment 1

Input:

InStream(Time, Val) = {(10,10),(11,20),(12,30),(13,40),(14,50),(15,60),
                       (16,70), ...}

Query:

Continuously compute the average value of the tuples in the input stream using a time-based tumbling window of 3 seconds.

Oracle CEP:

Query in Oracle CEP is as follows: 

ISTREAM(SELECT avg(Val) AS AggrValue
FROM InStream [RANGE 3 seconds SLIDE 3 seconds]) 

Result of the query in Oracle CEP is as follows:

Oracle CEP = {(20),(50),...}

Project and input files of the experiment can be found here.

StreamBase: 

Query in StreamBase is as follows:

CREATE OUTPUT STREAM timeR1 AS 
SELECT avg(Val) AS AvgVal
FROM InStream[SIZE 3 ADVANCE 3 ON tstamp];
 
Result of the query in StreamBase is as follows:
 
StreamBase = {(15),(40),...} 
 
Project files of the experiment can be found here.

Explanation of the results given by the engines can be found in Section 6.2.1 of our journal paper.