Class: Droonga::Plugins::Search::DistributedSearchPlanner
- Inherits:
-
DistributedCommandPlanner
- Object
- DistributedCommandPlanner
- Droonga::Plugins::Search::DistributedSearchPlanner
- Defined in:
- lib/droonga/plugins/search/distributed_search_planner.rb
Defined Under Namespace
Classes: QueryTransformer
Constant Summary
Constants inherited from DistributedCommandPlanner
DistributedCommandPlanner::DEFAULT_LIMIT, DistributedCommandPlanner::REDUCE_SUM
Instance Attribute Summary
Attributes inherited from DistributedCommandPlanner
Instance Method Summary collapse
-
#initialize(dataset, search_request_message) ⇒ DistributedSearchPlanner
constructor
A new instance of DistributedSearchPlanner.
- #plan ⇒ Object
Methods inherited from DistributedCommandPlanner
Constructor Details
#initialize(dataset, search_request_message) ⇒ DistributedSearchPlanner
Returns a new instance of DistributedSearchPlanner.
25 26 27 28 29 30 31 32 33 |
# File 'lib/droonga/plugins/search/distributed_search_planner.rb', line 25 def initialize(dataset, ) super @request = @source_message["body"] raise NoQuery.new unless @request @request = Marshal.load(Marshal.dump(@request)) @queries = @request["queries"] end |
Instance Method Details
#plan ⇒ Object
35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 |
# File 'lib/droonga/plugins/search/distributed_search_planner.rb', line 35 def plan raise Searcher::NoQuery.new if @queries.nil? or @queries.empty? Searcher::QuerySorter.validate_dependencies(@queries) ensure_unifiable! logger.debug("from", :queries => @request) @queries.each do |input_name, query| transform_query(input_name, query) end logger.debug("to", :queries => @request) broadcast(:body => @request) super end |