lib/riak/map_reduce/phase.rb in riak-client-2.2.0.pre1 vs lib/riak/map_reduce/phase.rb in riak-client-2.2.0
- old
+ new
@@ -29,11 +29,11 @@
# @option options [Symbol] :type one of :map, :reduce, :link
# @option options [String] :language ("javascript") "erlang" or "javascript"
# @option options [String, Array, Hash] :function In the case of Javascript, a literal function in a string, or a hash with :bucket and :key. In the case of Erlang, an Array of [module, function]. For a :link phase, a hash including any of :bucket, :tag or a WalkSpec.
# @option options [Boolean] :keep (false) whether to return the results of this phase
# @option options [Array] :arg (nil) any extra static arguments to pass to the phase
- def initialize(options={})
+ def initialize(options = {})
self.type = options[:type]
self.language = options[:language] || "javascript"
self.function = options[:function]
self.keep = options[:keep] || false
self.arg = options[:arg]
@@ -68,10 +68,10 @@
as_json.to_json(*a)
end
# Converts the phase to its JSON-compatible representation for job invocation.
# @return [Hash] a Hash-equivalent of the phase
- def as_json(options=nil)
+ def as_json(options = nil)
obj = case type
when :map, :reduce
defaults = {"language" => language, "keep" => keep}
case function
when Hash