EvalPythonExec Physical Operators¶
EvalPythonExec is an extension of the UnaryExecNode abstraction for unary physical operators that can evaluate PythonUDFs.
evaluate( funcs: Seq[ChainedPythonFunctions], argOffsets: Array[Array[Int]], iter: Iterator[InternalRow], schema: StructType, context: TaskContext): Iterator[InternalRow]
Evaluates PythonUDFs (and produces internal binary rows)
EvalPythonExec physical operator is executed
EvalPythonExec takes the following to be created:
- Result Attributes
- Child physical operator
EvalPythonExec is an abstract class and cannot be created directly. It is created indirectly for the concrete EvalPythonExecs.