FlatMapGroupsInPandasExec¶
FlatMapGroupsInPandasExec
is a unary physical operator (Spark SQL) to execute a PythonUDF.
FlatMapGroupsInPandasExec
represents a FlatMapGroupsInPandas logical operator at execution time.
Creating Instance¶
FlatMapGroupsInPandasExec
takes the following to be created:
- Grouping Attributes (Spark SQL)
- Function Expression (Spark SQL)
- Output Attributes (Spark SQL)
- Child Physical Operator (Spark SQL)
FlatMapGroupsInPandasExec
is created when:
BasicOperators
(Spark SQL) execution planning strategy is executed (on a logical query plan with FlatMapGroupsInPandas logical operators)
Last update: 2021-03-03