Class: Spark::Command::ForeachPartition

Inherits:
Object
  • Object
show all
Defined in:
lib/spark/command/basic.rb

Overview

ForeachPartition

Instance Method Summary collapse

Instance Method Details

#run(iterator) ⇒ Object 



248
249
250
251
 
# File 'lib/spark/command/basic.rb', line 248

def run(iterator, *)
  @partition_function.call(iterator)
  nil
end