You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@flink.apache.org by "Wang Chengyu (Jira)" <ji...@apache.org> on 2026/07/30 02:37:00 UTC

[jira] [Created] (FLINK-40261) Support Set semantics, pass-through columns and ROW Value State for Python PTF

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)