Skip to content

PythonRDD

PythonRDD is an RDD (RDD[Array[Byte]]) that uses PythonRunner (to compute a partition).

Creating Instance

PythonRDD takes the following to be created:

  • Parent RDD
  • PythonFunction
  • preservePartitoning flag
  • isFromBarrier flag (default: false)

PythonRDD is created when...FIXME


Last update: 2020-10-02