class Spark::Command::MapPartitions


MapPartitions

Public Instance Methods

run(iterator, *) click to toggle source
# File lib/spark/command/basic.rb, line 59
def run(iterator, *)
  # Do not use `super` because `@partition_function` can be method with 1 argument
  iterator = @partition_function.call(iterator)
  iterator
end