class Spark::Command::CombineByKey::Merge
Public Instance Methods
_run(iterator, *)
click to toggle source
# File lib/spark/command/pair.rb, line 46 def _run(iterator, *) combiners = {} iterator.each do |key, value| if combiners.has_key?(key) combiners[key] = @merge_combiners.call(combiners[key], value) else combiners[key] = value end end combiners end