class Spark::Command::Aggregate


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