class Spark::Command::ForeachPartition


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