CoalesceExec Unary Physical Operator¶

CoalesceExec is a unary physical operator that represents Repartition logical operator (with shuffle disabled) at execution.

Creating Instance¶

CoalesceExec takes the following to be created:

• Number of partitions
• Child physical operator

CoalesceExec is created when:

• BasicOperators execution planning strategy is executed (to plan a Repartition logical operator with shuffle disabled)

Executing Operator¶

doExecute(): RDD[InternalRow]

doExecute...FIXME

Output Data Partitioning Requirements¶

outputPartitioning: Partitioning

outputPartitioning is one of the following:

• SinglePartition for the number of partitions being 1
• UnknownPartitioning with the number of partitions