class Spark::Command::ForeachPartition
Public Instance Methods
run(iterator, *)
click to toggle source
# File lib/spark/command/basic.rb, line 248 def run(iterator, *) @partition_function.call(iterator) nil end