Class: Spark::Command::Reduce

Inherits:

Aggregate

Object
Aggregate
Spark::Command::Reduce

show all

Defined in:: lib/spark/command/basic.rb

Overview

Reduce

Instance Method Summary collapse

#run(iterator) ⇒ Object

Methods inherited from Aggregate

Instance Method Details

#run(iterator) ⇒ `Object`



223
224
225

# File 'lib/spark/command/basic.rb', line 223

def run(iterator, *)
  [iterator.reduce(&@reduce_func)]
end