class Spark::Command::FlatMap
Public Instance Methods
lazy_run(iterator, *)
click to toggle source
# File lib/spark/command/basic.rb, line 33 def lazy_run(iterator, *) iterator.flat_map do |item| @map_function.call(item) end end
run(iterator, *)
click to toggle source
Calls superclass method
Spark::Command::Map#run
# File lib/spark/command/basic.rb, line 27 def run(iterator, *) iterator = super iterator.flatten!(1) iterator end