class Spark::Command::MapPartitionsWithIndex
Public Instance Methods
run(iterator, index)
click to toggle source
# File lib/spark/command/basic.rb, line 46 def run(iterator, index) iterator = @partition_function.call(iterator, index) iterator end