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)