feat(frontend): support alias for window table function (#2633)

Signed-off-by: TennyZhuang <[email protected]>

src/frontend/src/binder/relation/mod.rs

@@ -173,7 +173,7 @@ impl Binder {
                         )
                     })?;
                     Ok(Relation::WindowTableFunction(Box::new(
-                        self.bind_window_table_function(kind, args)?,
+                        self.bind_window_table_function(alias, kind, args)?,
                     )))
                 }
             }

src/frontend/src/binder/relation/window_table_function.rs

@@ -18,7 +18,7 @@ use itertools::Itertools;
 use risingwave_common::catalog::Field;
 use risingwave_common::error::{ErrorCode, RwError};
 use risingwave_common::types::DataType;
-use risingwave_sqlparser::ast::{Expr, FunctionArg, FunctionArgExpr, ObjectName};
+use risingwave_sqlparser::ast::{Expr, FunctionArg, FunctionArgExpr, ObjectName, TableAlias};
 
 use super::{Binder, Relation, Result};
 use crate::expr::{ExprImpl, InputRef};
@@ -54,6 +54,7 @@ pub struct BoundWindowTableFunction {
 impl Binder {
     pub(super) fn bind_window_table_function(
         &mut self,
+        alias: Option<TableAlias>,
         kind: WindowTableFunctionKind,
         args: Vec<FunctionArg>,
     ) -> Result<BoundWindowTableFunction> {
@@ -77,7 +78,6 @@ impl Binder {
         }?;
         let (schema_name, table_name) = Self::resolve_table_name(table_name)?;
 
-        // TODO: support alias.
         let base = self.bind_table_or_source(&schema_name, &table_name, None)?;
 
         let Some(time_col_arg) = args.next() else {
@@ -136,8 +136,8 @@ impl Binder {
                 ]
                 .into_iter(),
             );
-        // TODO: support alias.
-        self.bind_context(columns, table_name.clone(), None)?;
+
+        self.bind_context(columns, table_name.clone(), alias)?;
 
         let exprs: Vec<_> = args
             .map(|arg| self.bind_function_arg(arg))

src/frontend/test_runner/tests/testdata/time_window.yaml

@@ -87,3 +87,20 @@
       StreamProject { exprs: [$0, $1, $2, $3] }
         StreamHopWindow { time_col: $1 slide: 1 day 00:00:00 size: 3 days 00:00:00 }
           StreamTableScan { table: t1, columns: [id, created_at, _row_id#0], pk_indices: [2] }
+- sql: |
+    create table t1 (id int, created_at date);
+    select t_hop.id, t_hop.created_at from hop(t1, created_at, interval '1' day, interval '3' day) as t_hop;
+  logical_plan: |
+    LogicalProject { exprs: [$1, $2] }
+      LogicalHopWindow { time_col: $2 slide: 1 day 00:00:00 size: 3 days 00:00:00 }
+        LogicalScan { table: t1, columns: [_row_id#0, id, created_at] }
+  batch_plan: |
+    BatchExchange { order: [], dist: Single }
+      BatchProject { exprs: [$0, $1] }
+        BatchHopWindow { time_col: $1 slide: 1 day 00:00:00 size: 3 days 00:00:00 }
+          BatchScan { table: t1, columns: [id, created_at] }
+  stream_plan: |
+    StreamMaterialize { columns: [id, created_at, _row_id#0(hidden), window_start(hidden)], pk_columns: [_row_id#0, window_start] }
+      StreamProject { exprs: [$0, $1, $2, $3] }
+        StreamHopWindow { time_col: $1 slide: 1 day 00:00:00 size: 3 days 00:00:00 }
+          StreamTableScan { table: t1, columns: [id, created_at, _row_id#0], pk_indices: [2] }