class Spark::Command::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