TIME-BASED WINDOW EXPERIMENT 3

Time-based Window Experiment 3

 Input: 

InStream(Time, Val) = {(3,10),(5,20),(5,30),(5,40),(5,50),(7,60), ...}
 
We configured input stream in three different ways: STuple (one tuple per batch), STime (all simutaneous tuples in the same batch), and SBatch (two simultaneous tuples per batch). As discussed in Setup of Coral8, STime and SBatch are derived streams obtained by using joins. Details can be found in query files of the experiment. 

Query:

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

Coral8: 

Query in Coral8 is as follows:  

INSERT INTO TimeR3
SELECT sum(Val)
FROM InStream
KEEP 4 SECONDS;

Result of the query in Coral8 is as follows:

Coral8(tuple-driven) = {(10),(30),(60),(100),(150), ...}
Coral8(time-driven)  = {(10),(150), ...}
Coral8(batch-driven) = {(10),(60),(150), ...}

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

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