TIME-BASED WINDOW EXPERIMENT 4

Time-based Window Experiment 4

Input: 

InStream(Time, Val) = {(3,10),(5,20),(5,30),(5,40),(5,50),(7,60), ...}

Query:

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

Oracle CEP:

Query in Oracle CEP is as follows:

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

Result of the query in Oracle CEP is as follows:

Oracle CEP = {(10),(150),...}

Project and input files can be found here.

STREAM: 

Query in STREAM is as follows:

ISTREAM( SELECT SUM(Val)
FROM InStream [RANGE 4 SECONDS]);

Result of the query in STREAM is as follows:

STREAM = {(10),(150),...}

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

StreamBase: 

Query in StreamBase is as follows:

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