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 <
// FIXME: DEMO import org.apache.spark.sql.catalyst.optimizer.CollapseWindow
val logicalPlan = ??? val afterCollapseWindow = CollapseWindow(logicalPlan)
apply(plan: LogicalPlan): LogicalPlan
apply is part of the Rule abstraction.