Wang Chengyu created FLINK-40261:
------------------------------------

             Summary: Support Set semantics, pass-through columns and ROW Value 
State for Python PTF
                 Key: FLINK-40261
                 URL: https://issues.apache.org/jira/browse/FLINK-40261
             Project: Flink
          Issue Type: Sub-task
            Reporter: Wang Chengyu


Add keyed/stateful single-table processing on top of the stateless path.

Scope:
* Set semantics with required/optional PARTITION BY and partition-key prefix.
* Pass-through columns.
* One or more keyed ROW Value State with mutable Row injection, independent TTL,
  and explicit cleanup (clear_state / clear_all_state).

Depends on: "Python PTF definition API and stateless runtime path".



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

Reply via email to