[jira] [Closed] (FLINK-39254) FLIP-565: Improve ProcessTableFunctions for late data handling and state access

["Timo Walther (Jira)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/FLINK-39254?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Timo Walther closed FLINK-39254.
--------------------------------
    Fix Version/s: 2.4.0
       Resolution: Fixed

FLIP has been fully implemented in Flink 2.4

> FLIP-565: Improve ProcessTableFunctions for late data handling and state access
> -------------------------------------------------------------------------------
>
>                 Key: FLINK-39254
>                 URL: https://issues.apache.org/jira/browse/FLINK-39254
>             Project: Flink
>          Issue Type: New Feature
>          Components: Table SQL / API, Table SQL / Planner, Table SQL / Runtime
>            Reporter: Timo Walther
>            Assignee: Timo Walther
>            Priority: Major
>             Fix For: 2.4.0
>
>
> The ProcessTableFunction (PTF) feature has been well received by the Flink community and its adoption is increasing. Some design decisions need smaller adjustments along late data handling and lazy state access.
> This FLIP includes 3 PTF improvements:
> 1) Don’t drop late data in ProcessFunction as data-loss is usually not intended; similar to DataStream API’s ProcessFunction
> 2) Introduce ValueView to enable a “supplier”-pattern for state access; similar to MapView and ListView
> 3) Introduce BROADCAST_SEMANTIC_TABLE as a new kind of argument to PTFs
> See: https://cwiki.apache.org/confluence/display/FLINK/FLIP-565%3A+Improve+ProcessTableFunctions+for+late+data+handling+and+state+access



--
This message was sent by Atlassian Jira
(v8.20.10#820010)