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