Navigation Menu

Skip to content

Commit

Permalink
test: add columns[NAME].window.group_keys test case without cache
Browse files Browse the repository at this point in the history
When the value of --columns[NAME].window.group_keys parameter is
changed, Groonga returns result without using cache.
  • Loading branch information
kenhys committed Apr 20, 2017
1 parent b46c205 commit ff8a321
Show file tree
Hide file tree
Showing 2 changed files with 175 additions and 0 deletions.
@@ -0,0 +1,130 @@
plugin_register sharding
[[0,0.0,0.0],true]
table_create Logs_20170415 TABLE_NO_KEY
[[0,0.0,0.0],true]
column_create Logs_20170415 timestamp COLUMN_SCALAR Time
[[0,0.0,0.0],true]
column_create Logs_20170415 price COLUMN_SCALAR UInt32
[[0,0.0,0.0],true]
column_create Logs_20170415 n_likes COLUMN_SCALAR UInt32
[[0,0.0,0.0],true]
table_create Logs_20170416 TABLE_NO_KEY
[[0,0.0,0.0],true]
column_create Logs_20170416 timestamp COLUMN_SCALAR Time
[[0,0.0,0.0],true]
column_create Logs_20170416 price COLUMN_SCALAR UInt32
[[0,0.0,0.0],true]
column_create Logs_20170416 n_likes COLUMN_SCALAR UInt32
[[0,0.0,0.0],true]
load --table Logs_20170415
[
{"timestamp": "2017/04/15 00:00:00", "n_likes": 2, "price": 100},
{"timestamp": "2017/04/15 01:00:00", "n_likes": 1, "price": 100},
{"timestamp": "2017/04/15 01:00:00", "n_likes": 2, "price": 200}
]
[[0,0.0,0.0],3]
load --table Logs_20170416
[
{"timestamp": "2017/04/16 10:00:00", "n_likes": 1, "price": 200},
{"timestamp": "2017/04/16 11:00:00", "n_likes": 2, "price": 300},
{"timestamp": "2017/04/16 11:00:00", "n_likes": 1, "price": 300}
]
[[0,0.0,0.0],3]
logical_select Logs --shard_key timestamp --columns[sum].stage initial --columns[sum].type UInt32 --columns[sum].flags COLUMN_SCALAR --columns[sum].value 'window_sum(price)' --columns[sum].window.group_keys n_likes --output_columns price,sum
[
[
0,
0.0,
0.0
],
[
[
[
6
],
[
[
"price",
"UInt32"
],
[
"sum",
"UInt32"
]
],
[
100,
300
],
[
100,
100
],
[
200,
300
],
[
200,
500
],
[
300,
300
],
[
300,
500
]
]
]
]
logical_select Logs --shard_key timestamp --columns[sum].stage initial --columns[sum].type UInt32 --columns[sum].flags COLUMN_SCALAR --columns[sum].value 'window_sum(price)' --columns[sum].window.group_keys price --output_columns price,sum
[
[
0,
0.0,
0.0
],
[
[
[
6
],
[
[
"price",
"UInt32"
],
[
"sum",
"UInt32"
]
],
[
100,
200
],
[
100,
200
],
[
200,
200
],
[
200,
200
],
[
300,
600
],
[
300,
600
]
]
]
]
@@ -0,0 +1,45 @@
#@on-error omit
plugin_register sharding
#@on-error default

table_create Logs_20170415 TABLE_NO_KEY
column_create Logs_20170415 timestamp COLUMN_SCALAR Time
column_create Logs_20170415 price COLUMN_SCALAR UInt32
column_create Logs_20170415 n_likes COLUMN_SCALAR UInt32

table_create Logs_20170416 TABLE_NO_KEY
column_create Logs_20170416 timestamp COLUMN_SCALAR Time
column_create Logs_20170416 price COLUMN_SCALAR UInt32
column_create Logs_20170416 n_likes COLUMN_SCALAR UInt32

load --table Logs_20170415
[
{"timestamp": "2017/04/15 00:00:00", "n_likes": 2, "price": 100},
{"timestamp": "2017/04/15 01:00:00", "n_likes": 1, "price": 100},
{"timestamp": "2017/04/15 01:00:00", "n_likes": 2, "price": 200}
]

load --table Logs_20170416
[
{"timestamp": "2017/04/16 10:00:00", "n_likes": 1, "price": 200},
{"timestamp": "2017/04/16 11:00:00", "n_likes": 2, "price": 300},
{"timestamp": "2017/04/16 11:00:00", "n_likes": 1, "price": 300}
]

logical_select Logs \
--shard_key timestamp \
--columns[sum].stage initial \
--columns[sum].type UInt32 \
--columns[sum].flags COLUMN_SCALAR \
--columns[sum].value 'window_sum(price)' \
--columns[sum].window.group_keys n_likes \
--output_columns price,sum

logical_select Logs \
--shard_key timestamp \
--columns[sum].stage initial \
--columns[sum].type UInt32 \
--columns[sum].flags COLUMN_SCALAR \
--columns[sum].value 'window_sum(price)' \
--columns[sum].window.group_keys price \
--output_columns price,sum

0 comments on commit ff8a321

Please sign in to comment.