[Groonga-commit] droonga/fluent-plugin-droonga at 0f8b9eb [master] Use "average" reducer

Back to archive index

YUKI Hiroshi null+****@clear*****
Fri Jan 24 17:59:51 JST 2014


YUKI Hiroshi	2014-01-24 17:59:51 +0900 (Fri, 24 Jan 2014)

  New Revision: 0f8b9ebf187fc3399cb1500314e3aac62a822891
  https://github.com/droonga/fluent-plugin-droonga/commit/0f8b9ebf187fc3399cb1500314e3aac62a822891

  Message:
    Use "average" reducer

  Modified files:
    lib/droonga/plugin/collector/basic.rb
    lib/droonga/plugin/collector/groonga.rb

  Modified: lib/droonga/plugin/collector/basic.rb (+2 -0)
===================================================================
--- lib/droonga/plugin/collector/basic.rb    2014-01-24 17:55:02 +0900 (ebc123f)
+++ lib/droonga/plugin/collector/basic.rb    2014-01-24 17:59:51 +0900 (97c7b7c)
@@ -51,6 +51,8 @@ module Droonga
           reduced_value = left_value && right_value
         when "sum"
           reduced_value = left_value + right_value
+        when "average"
+          reduced_value = (left_value + right_value) / 2
         when "sort"
           reduced_value = merge(left_value,
                                 right_value,

  Modified: lib/droonga/plugin/collector/groonga.rb (+6 -4)
===================================================================
--- lib/droonga/plugin/collector/groonga.rb    2014-01-24 17:55:02 +0900 (1057004)
+++ lib/droonga/plugin/collector/groonga.rb    2014-01-24 17:59:51 +0900 (66510e7)
@@ -64,13 +64,15 @@ module Droonga
       right_status = right_header.shift
       status = [left_status, right_status].min
 
-      left_start_time = left_header.shift
-      right_start_time = right_header.shift
-      start_time = (left_start_time + right_start_time) / 2
+      start_time = reduce({ "type" => "average" },
+                          left_header.shift,
+                          right_header.shift)
 
       left_elapsed_time = left_header.shift
       right_elapsed_time = right_header.shift
-      elapsed_time = (left_elapsed_time + right_elapsed_time) / 2
+      elapsed_time = reduce({ "type" => "average" },
+                          left_header.shift,
+                          right_header.shift)
 
       #XXX we should merge error informations more smarter...
       error_information = left_header + right_header
-------------- next part --------------
HTML����������������������������...
Download 



More information about the Groonga-commit mailing list
Back to archive index