[
https://issues.apache.org/jira/browse/FLINK-40885?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
ASF GitHub Bot updated FLINK-40885:
-----------------------------------
Labels: pull-request-available (was: )
> Support LATERAL SNAPSHOT join in the Table API
> ----------------------------------------------
>
> Key: FLINK-40885
> URL: https://issues.apache.org/jira/browse/FLINK-40885
> Project: Flink
> Issue Type: Improvement
> Components: Table SQL / API
> Reporter: Fabian Hueske
> Assignee: Fabian Hueske
> Priority: Major
> Labels: pull-request-available
>
> The SNAPSHOT process-table function (FLINK-39783 et al.) can currently only
> be used via SQL (JOIN LATERAL SNAPSHOT(...)). The programmatic Table API
> cannot express an equivalent joinLateral / leftOuterJoinLateral with
> call("SNAPSHOT", ...) — it fails during planning or API validation.
> Three gaps:
> - QueryOperationConverter does not convert a TABLE argument of a correlated
> function into a table-scan input, and wraps the call in a Correlate (not a
> LogicalJoin), so the LATERAL SNAPSHOT rewrite rule never matches for INNER
> joins.
> - CorrelatedFunctionTableFactory rejects .as(...) on SNAPSHOT because it is
> PROCESS_TABLE, not TABLE.
> - JoinOperationFactory forbids an ON predicate on a lateral left outer join,
> which SNAPSHOT requires.
> Goal: enable joinLateral / leftOuterJoinLateral with SNAPSHOT so the Table
> API produces the same plan as the equivalent SQL, covering INNER, LEFT OUTER,
> column aliases, and a Table-valued build side.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
