[
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)
