Skip to content

CollapseWindow Logical Optimization

CollapseWindow is a base logical optimization that <>.

CollapseWindow is part of the Operator Optimization fixed-point batch in the standard batches of the Logical Optimizer.

CollapseWindow is simply a <> for transforming <>, i.e. Rule[LogicalPlan].

[source, scala]

// FIXME: DEMO import org.apache.spark.sql.catalyst.optimizer.CollapseWindow

val logicalPlan = ??? val afterCollapseWindow = CollapseWindow(logicalPlan)


Executing Rule

apply(plan: LogicalPlan): LogicalPlan

apply...FIXME

apply is part of the Rule abstraction.


Last update: 2020-08-05
Back to top