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.