Method: Spark::Command::CombineByKey::Merge#_run

Defined in:
lib/spark/command/pair.rb

#_run(iterator) ⇒ Object 



46
47
48
49
50
51
52
53
54
55
56
 
# 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