class Spark::Command::FlatMapValues


FlatMapValues

Public Instance Methods

run(iterator, *) click to toggle source
# File lib/spark/command/pair.rb, line 113
def run(iterator, *)
  iterator.map! do |(key, values)|
    values = @map_function.call(values)
    values.flatten!(1)
    values.map! do |value|
      [key, value]
    end
  end
  iterator.flatten!(1)
  iterator
end