class Spark::Command::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