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
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
|
#include "sp_cb_functions.h"
#ifndef FLB_TEST_SP_SELECT_KEYS
#define FLB_TEST_SP_SELECT_KEYS
/* Tests for 'test_select_keys' */
struct task_check select_keys_checks[] = {
{
0, 0, 0, 0,
"select_all",
"SELECT * FROM STREAM:FLB;",
cb_select_all
},
{
1, 0, 0, 0,
"select_id",
"SELECT id, word2 FROM STREAM:FLB;",
cb_select_id
},
/* Conditionals */
{
2, 0, 0, 0,
"select_cond_1",
"SELECT * FROM STREAM:FLB WHERE bytes > 10.290;",
cb_select_cond_1
},
{
3, 0, 0, 0,
"select_cond_2",
"SELECT * FROM STREAM:FLB WHERE word2 = 'rlz' or word3 = 'rlz';",
cb_select_cond_2
},
{
4, 0, 0, 0,
"select_cond_not_null",
"SELECT * FROM STREAM:FLB WHERE word2 = 'rlz' and word3 IS NOT NULL;",
cb_select_cond_not_null
},
{
5, 0, 0, 0,
"select_cond_null",
"SELECT * FROM STREAM:FLB WHERE word3 IS NULL;",
cb_select_cond_null
},
{
6, 0, 0, 0,
"select_not_equal_1",
"SELECT * FROM STREAM:FLB WHERE bool != true;",
cb_select_not_equal_1
},
{
7, 0, 0, 0,
"select_not_equal_2",
"SELECT * FROM STREAM:FLB WHERE bytes <> 10;",
cb_select_not_equal_2
},
/* Aggregation functions */
{
8, 0, 0, 0,
"select_aggr",
"SELECT MIN(id), MAX(id), COUNT(*), SUM(bytes), AVG(bytes) " \
"FROM STREAM:FLB;",
cb_select_aggr,
},
{
9, 0, 0, 0,
"select_aggr_coount",
"SELECT COUNT(*) " \
"FROM STREAM:FLB;",
cb_select_aggr_count,
},
{
10, 0, 0, 0,
"select_aggr_window_tumbling",
"SELECT MIN(id), MAX(id), COUNT(*), SUM(bytes), AVG(bytes) FROM STREAM:FLB;",
cb_select_aggr,
},
{
11, 0, 0, 0,
"select_aggr_window_tumbling_groupby",
"SELECT bool, MIN(id), MAX(id), COUNT(*), SUM(bytes), AVG(bytes) " \
"FROM STREAM:FLB WHERE word3 IS NOT NULL GROUP BY bool;",
cb_select_groupby,
},
/* Time functions */
{
12, 0, 0, 0,
"func_time_now",
"SELECT NOW(), NOW() as tnow FROM STREAM:FLB WHERE bytes > 10;",
cb_func_time_now,
},
{
13, 0, 0, 0,
"func_time_unix_timestamp",
"SELECT UNIX_TIMESTAMP(), UNIX_TIMESTAMP() as ts " \
"FROM STREAM:FLB WHERE bytes > 10;",
cb_func_time_unix_timestamp,
},
/* Stream selection using Tag rules */
{
14, 0, 0, 0,
"select_from_tag_error",
"SELECT id FROM TAG:'no-matches' WHERE bytes > 10;",
cb_select_tag_error,
},
{
15, 0, 0, 0,
"select_from_tag",
"SELECT id FROM TAG:'samples' WHERE bytes > 10;",
cb_select_tag_ok,
},
{
16, 0, 0, 0,
"@recond.contains",
"SELECT id FROM TAG:'samples' WHERE bytes = 10 AND @record.contains(word2);",
cb_record_contains,
},
{
17, 0, 0, 0,
"@recond.contains",
"SELECT id FROM TAG:'samples' WHERE @record.contains(x);",
cb_record_not_contains,
},
};
#endif
|
