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 is part of the Rule abstraction.