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