class Spark::Command::MapPartitionsWithIndex


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