droonga/fluent-plugin-droonga at 878278f [master] Support search operation. (Groonga-commit) - Groonga - fulltext search engine.

Daijiro MORI	2013-09-06 19:23:29 +0900 (Fri, 06 Sep 2013)

  New Revision: 878278f3d60774c5c0cc49810e29b59a6953ece0
  https://github.com/droonga/fluent-plugin-droonga/commit/878278f3d60774c5c0cc49810e29b59a6953ece0

  Message:
    Support search operation.

  Modified files:
    lib/droonga/adapter.rb

  Modified: lib/droonga/adapter.rb (+60 -1)
===================================================================

--- lib/droonga/adapter.rb    2013-09-06 17:11:30 +0900 (7dc22f5)
+++ lib/droonga/adapter.rb    2013-09-06 19:23:29 +0900 (b2b3a26)
@@ -43,6 +43,10 @@ module Droonga
       }]
       post(message, "proxy")
     end
+
+    def prefer_synchronous?(command)
+      return true
+    end
   end
 
   class BasicAdapter < Adapter
@@ -60,9 +64,64 @@ module Droonga
 
     command :add
     def add(request)
-      # TOOD: update event must be serialized in the primary node
+      # TOOD: update events must be serialized in the primary node of replicas.
       key = request["key"] || rand.to_s
       scatter_all(request, key)
     end
+
+    command :search
+    def search(request)
+      message = []
+      input_names = []
+      output_names = []
+      name_mapper = {}
+      request["queries"].each do |input_name, query|
+        output = query["output"]
+        next unless output
+        input_names << input_name
+        output_name = input_name + "_reduced"
+        output_names << output_name
+        name_mapper[output_name] = input_name
+        # TODO: offset & limit must be arranged here.
+        elements = {}
+        output["elements"].each do |element|
+          case element
+          when "count"
+            elements[element] = ["sum"]
+          when "records"
+            # TODO: must take "sortBy" section into account.
+            elements[element] = ["sort", "<"]
+          end
+        end
+        reducer = {
+          "inputs"=> [input_name],
+          "outputs"=> [output_name],
+          "type"=> "reduce",
+          "body"=> {
+            input_name=> {
+              output_name=> elements
+            }
+          }
+        }
+        message << reducer
+      end
+      gatherer = {
+        "inputs"=> output_names,
+        "type"=> "gather",
+        "body"=> name_mapper,
+        "post"=> true
+      }
+      message << gatherer
+      searcher = {
+        "dataset"=> envelope["dataset"] || request["dataset"],
+        "outputs"=> input_names,
+        "type"=> "broadcast",
+        "command"=> "search",
+        "replica"=> "random",
+        "body"=> request
+      }
+      message.push(searcher)
+      post(message, "proxy")
+    end
   end
 end
-------------- next part --------------
HTML����������������������������...
Download 


Groonga - fulltext search engine.

[Groonga-commit] droonga/fluent-plugin-droonga at 878278f [master] Support search operation.