UnaryExecNode Physical Operators¶

UnaryExecNode is an extension of the SparkPlan abstraction for unary physical operators (with one child physical operator only).

Contract¶

Child Physical Operator¶

child: SparkPlan

The one and only child physical operator

Used when:

• UnaryExecNode is requested for the children
• others

Implementations¶

• AggregateInPandasExec (PySpark)
• PartitioningPreservingUnaryExecNode
• BaseAggregateExec
• CoalesceExec
• CollectMetricsExec
• ColumnarToRowExec
• DataWritingCommandExec
• DebugExec
• EvalPythonExec
• Exchange
• FilterExec
• FlatMapGroupsInPandasExec (PySpark)
• FlatMapGroupsWithStateExec (Structured Streaming)
• GenerateExec
• InputAdapter
• ObjectConsumerExec
• ProjectExec
• SortExec
• SubqueryExec
• V2TableWriteExec
• WholeStageCodegenExec
• others