Timo Walther created FLINK-39254:
------------------------------------
Summary: 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
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)
