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
53
|
#include "sp_cb_functions.h"
#ifndef FLB_TEST_SP_WINDOW
#define FLB_TEST_SP_WINDOW
/* Tests for test_window */
struct task_check window_checks[] = {
{
0, FLB_SP_WINDOW_TUMBLING, 5, 0,
"window_5_seconds",
"SELECT SUM(id), AVG(id) FROM STREAM:FLB WINDOW TUMBLING (5 SECOND) " \
"WHERE word3 IS NOT NULL;",
cb_window_5_second
},
{
1, FLB_SP_WINDOW_TUMBLING, 1, 0,
"select_aggr_window_tumbling",
"SELECT MIN(id), MAX(id), COUNT(*), SUM(bytes), AVG(bytes) " \
"FROM STREAM:FLB WINDOW TUMBLING (1 SECOND);",
cb_select_aggr,
},
{
2, FLB_SP_WINDOW_TUMBLING, 1, 0,
"select_aggr_window_tumbling_groupby",
"SELECT bool, MIN(id), MAX(id), COUNT(*), SUM(bytes), AVG(bytes) " \
"FROM STREAM:FLB WINDOW TUMBLING (1 SECOND) WHERE word3 IS NOT NULL " \
"GROUP BY bool;",
cb_select_groupby,
},
{
3, FLB_SP_WINDOW_HOPPING, 5, 2,
"hopping_window_5_seconds",
"SELECT SUM(id), AVG(id) FROM STREAM:FLB WINDOW HOPPING (5 SECOND, " \
"ADVANCE BY 2 SECOND) WHERE word3 IS NOT NULL;",
cb_hopping_window_5_second
},
{ /* FORECAST */
4, FLB_SP_WINDOW_TUMBLING, 1, 0,
"timeseries_forecast_window_tumbling",
"SELECT AVG(usage), TIMESERIES_FORECAST(usage, 20) FROM " \
"STREAM:FLB WINDOW TUMBLING (5 SECOND);",
cb_forecast_tumbling_window
},
{
5, FLB_SP_WINDOW_HOPPING, 5, 2,
"timeseries_forecast_window_hopping",
"SELECT AVG(usage), TIMESERIES_FORECAST(usage, 20) FROM " \
"STREAM:FLB WINDOW HOPPING (5 SECOND, ADVANCE BY 2 SECOND);",
cb_forecast_hopping_window
},
};
#endif
|
