class Spark::Command::Reduce
Public Instance Methods
run(iterator, *)
click to toggle source
# File lib/spark/command/basic.rb, line 223 def run(iterator, *) [iterator.reduce(&@reduce_func)] end
# File lib/spark/command/basic.rb, line 223 def run(iterator, *) [iterator.reduce(&@reduce_func)] end