TUPLE-BASED WINDOW EXPERIMENT 3

Tuple-based Window Experiment 3

Input: 

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

Query:

Continuously compute the average value of the tuples over a tumbling window of size 1 tuple.

Coral8: 

Query in Coral8 is as follows:

INSERT INTO R3
SELECT avg(Val)
FROM InStream
KEEP EVERY 1 ROW;

Result of the query in Coral8 is as follows:

Coral8 = {(10),(20),(30),(40),(50),(60),(70),(80),(90), ...}

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

Oracle CEP:

Query in Oracle CEP is as follows:

ISTREAM(SELECT avg(Val) AS AggrValue
FROM InStream [ROWS 1 SLIDE 1])

Result of the query in Oracle CEP is as follows:

Oracle CEP = {(20),(30),(70),(80),(90), ...}

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

STREAM: 

Query in STREAM is as follows:

ISTREAM( SELECT AVG(Val)
FROM InStream [ROWS 1]);

Result of the query in STREAM is as follows:

STREAM = {(20),(30),(70),(80),(90), ...}

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

StreamBase: 

Query in StreamBase is as follows:

CREATE OUTPUT STREAM tupleR3 AS
SELECT avg(Val) AS AvgVal
FROM InStream[SIZE 1 ADVANCE 1 TUPLES];
 
Result of the query in StreamBase is as follows:
 
StreamBase = {(10),(20),(30),(40),(50),(60),(70),(80),(90), ...}
 
Project files of the experiment can be found here.
 
Explanation of the results given by the engines can be found in Section 6.3.3 of our journal paper.