TIME-BASED WINDOW EXPERIMENT 5

Time-based Window Experiment 5

Input: 

InStream(Time, Val) = {(11,10),(12,20),(13,30),(14,40),(15,50),(16,60),
                       (17,70),(18,80),(19,90),(20,100), ...}

Query:

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

Coral8: 

Query in Coral8 is as follows:

INSERT INTO R5
SELECT sum(Val)
FROM InStream
KEEP EVERY 3 SECONDS;

Result of the query in Coral8 is as follows:

Coral8 = {(10),(20),(50),(90),(50),(110),(180),(80),(170), ...}

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

Oracle CEP:

Query in Oracle CEP is as follows:

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

Result of the query in Oracle CEP is as follows:

Oracle CEP = {(30),(120),(210),...}

Project and input files can be found here.

StreamBase: 

Query in StreamBase is as follows:

CREATE OUTPUT STREAM timeR5 AS
SELECT sum(Val) AS SumVal
FROM InStream[SIZE 3 ADVANCE 3 ON tstamp];
 
Result of the query in StreamBase is as follows:
 
StreamBase = {(10),(90),(180), ...} 
 
Project files of the experiment can be found here.
 
Explanation of the results given by the engines can be found in Section 6.2.5 of our journal paper.