Kouhei Sutou
null+****@clear*****
Wed Dec 6 15:56:09 JST 2017
Kouhei Sutou 2017-12-06 15:56:09 +0900 (Wed, 06 Dec 2017) New Revision: c50dec6519c80f6682b330fb6869e7e3ed2336bb https://github.com/groonga/groonga/commit/c50dec6519c80f6682b330fb6869e7e3ed2336bb Message: logical_select: log N selected in each shard Modified files: plugins/sharding/logical_select.rb test/command/suite/sharding/logical_select/columns/stage/filtered/filter.expected test/command/suite/sharding/logical_select/columns/stage/filtered/filter.test Modified: plugins/sharding/logical_select.rb (+7 -0) =================================================================== --- plugins/sharding/logical_select.rb 2017-12-06 15:06:13 +0900 (c64c11b21) +++ plugins/sharding/logical_select.rb 2017-12-06 15:56:09 +0900 (63ee677db) @@ -770,6 +770,9 @@ module Groonga end def add_result_set(result_set, condition) + query_logger.log(:size, ":", + "select(#{result_set.size}): #{@shard.table_name}") + if result_set.empty? result_set.close return @@ -790,6 +793,10 @@ module Groonga @result_sets << sorted_result_set end end + + def query_logger + Context.instance.query_logger + end end end end Modified: test/command/suite/sharding/logical_select/columns/stage/filtered/filter.expected (+9 -0) =================================================================== --- test/command/suite/sharding/logical_select/columns/stage/filtered/filter.expected 2017-12-06 15:06:13 +0900 (3c55a13b9) +++ test/command/suite/sharding/logical_select/columns/stage/filtered/filter.expected 2017-12-06 15:56:09 +0900 (cd5739748) @@ -90,3 +90,12 @@ logical_select Logs --shard_key timestamp --columns[filtered_id].stage filte ] ] ] +#>logical_select --columns[filtered_id].flags "COLUMN_SCALAR" --columns[filtered_id].stage "filtered" --columns[filtered_id].type "UInt32" --columns[filtered_id].value "_id" --filter "price < 910" --logical_table "Logs" --output_columns "_id,filtered_id,price" --shard_key "timestamp" +#:000000000000000 filter(1) +#:000000000000000 select(1): Logs_20170315 +#:000000000000000 filter(2) +#:000000000000000 select(2): Logs_20170316 +#:000000000000000 filter(2) +#:000000000000000 select(2): Logs_20170317 +#:000000000000000 output(5) +#<000000000000000 rc=0 Modified: test/command/suite/sharding/logical_select/columns/stage/filtered/filter.test (+2 -0) =================================================================== --- test/command/suite/sharding/logical_select/columns/stage/filtered/filter.test 2017-12-06 15:06:13 +0900 (acb310aca) +++ test/command/suite/sharding/logical_select/columns/stage/filtered/filter.test 2017-12-06 15:56:09 +0900 (6a70fa5fa) @@ -32,6 +32,7 @@ load --table Logs_20170317 {"timestamp": "2017/03/17 20:00:00", "price": 300} ] +#@collect-query-log true logical_select Logs \ --shard_key timestamp \ --columns[filtered_id].stage filtered \ @@ -40,3 +41,4 @@ logical_select Logs \ --columns[filtered_id].value '_id' \ --filter 'price < 910' \ --output_columns _id,filtered_id,price +#@collect-query-log false -------------- next part -------------- HTML����������������������������... URL: https://lists.osdn.me/mailman/archives/groonga-commit/attachments/20171206/0881ece1/attachment-0001.htm
