PythonRunner¶

PythonRunner is a concrete BasePythonRunner.

Creating Instance¶

PythonRunner takes the following to be created:

• ChainedPythonFunctionses

PythonRunner is created (indirectly using apply factory method) when:

• PythonRDD is requested to compute a partition
• PythonForeachWriter is requested for a PythonRunner

Creating PythonRunner¶

apply(
  func: PythonFunction): PythonRunner

apply simply creates a PythonRunner for the PythonFunction.

apply is used when:

• PythonRDD is requested to compute a partition
• PythonForeachWriter is requested for a PythonRunner