[FLINK-25363] Replace LogicalWindow and related planner expressions

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.15.0
• Component/s: API / Python, Table SQL / Planner
• Labels: pull-request-available
• Assignee: Francesco Guardiani
• Reporter: Timo Walther
• Created: 17/Dec/21 12:59
• Updated: 21/Dec/21 12:35
• Resolved: 21/Dec/21 12:35

Description

The following classes are legacy from the old Table API.

import org.apache.flink.table.planner.expressions.PlannerNamedWindowProperty;
import org.apache.flink.table.planner.expressions.PlannerProctimeAttribute;
import org.apache.flink.table.planner.expressions.PlannerRowtimeAttribute;
import org.apache.flink.table.planner.expressions.PlannerWindowEnd;
import org.apache.flink.table.planner.expressions.PlannerWindowProperty;
import org.apache.flink.table.planner.expressions.PlannerWindowStart;
import org.apache.flink.table.planner.plan.logical.LogicalWindow;
import org.apache.flink.table.planner.plan.logical.SessionGroupWindow;
import org.apache.flink.table.planner.plan.logical.SlidingGroupWindow;
import org.apache.flink.table.planner.plan.logical.TumblingGroupWindow;

However, currently they are used in ExecNode and partially are serialized into the JSON plan. Also Python depends on it. Instead we should introduce a small POJO structure with enums. E.g. WindowSpec with WindowProperty enum or so. It can be located in the runtime module if Python needs this information during runtime.

Issue Links

• links to: GitHub Pull Request #18154