-
Notifications
You must be signed in to change notification settings - Fork 3
/
Copy pathChangeLog
52 lines (36 loc) · 1.65 KB
/
ChangeLog
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
Version 0.5.0
The first public release version
Version 0.5.1
Fixed minor bugs:
- Relation Source operator
- 2 bugs in partition window store
Version 0.6.1
- Added slide parameter to range windows.
A slide must be specified immediately after the window operator
RANGE. It is currently not possible to define a slide together
with the ROWS operator. The slide is expressed using the same
time specification as range.
Finally, specifying a range smaller than the slide has undefined
results.
The following example query defines a window with a range of 10
seconds, and a slide of 5 seconds:
SELECT *
FROM S [RANGE 10 SECONDS SLIDE 5 SECONDS];
When a tuple arrives with a time stamp which cannot be included in
the 10 second range (because the distance from the oldest tuple in
the window, to the most recently arrived, is greater than 10
seconds), the window will make some number of 5 second
slides. Most often one slide will be enough, but if the stream
hasn't produced any tuples for more than 5 seconds, more than one
slide will be required. Once the window has moved, all tuples with
time stamps between the windows original position and the new one
will be dropped.
The window [RANGE 1 DAY SLIDE 1 DAY] is equivalent to the ``Today
Window'' described at http://infolab.stanford.edu/stream/cql-benchmark.html.
It can be used to define the ExpOutStr stream in the following
way:
SELECT RSTREAM(query_id, E.car_id, -1 * SUM(credit))
FROM ExpQueryStr [NOW] as Q, AccTransStr [RANGE 1 DAY SLIDE 1 DAY] as T
WHERE Q.car_id = T.car_id;
If you have any questions about the slide parameter you can contact
me at [email protected].