TIME-BASED WINDOW EXPERIMENT 2

Time-based Window Experiment 2

Input: 

InStream(Time, Val) = {(30,10),(31,20),(36,30), ...}

Query:

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

Coral8: 

Query in Coral8 is as follows:

INSERT INTO R2
SELECT avg(Val)
FROM InStream
KEEP 5 SECONDS;

Result of the query in Coral8 is as follows:

Coral8 = {(10),(15),(20),...}

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 [RANGE 5 seconds])

Result of the query in Oracle CEP is as follows:

Oracle CEP = {(10),(15),(20),...}

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

STREAM: 

Query in STREAM is as follows:

ISTREAM( SELECT AVG(Val)
FROM InStream [RANGE 5 SECONDS]);

Result of the query in STREAM is as follows:

STREAM = {(10),(15),(20),...}

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

StreamBase: 

Query in StreamBase is as follows:

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

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