Class: Spark::Command::MapPartitionsWithIndex

Inherits:

Object

• Object
• Spark::Command::MapPartitionsWithIndex

Defined in:

lib/spark/command/basic.rb

Overview

---

MapPartitionsWithIndex

Direct Known Subclasses

MapPartitions

Instance Method Summary

• #run(iterator, index) ⇒ Object

Instance Method Details

#run(iterator, index) ⇒ Object

# File 'lib/spark/command/basic.rb', line 46

def run(iterator, index)
  iterator = @partition_function.call(iterator, index)
  iterator
end