xuhuang created FLINK-37290:
-------------------------------
Summary: Introduce endPartition to DataStream V2 ProcessFunction
Key: FLINK-37290
URL: https://issues.apache.org/jira/browse/FLINK-37290
Project: Flink
Issue Type: New Feature
Components: API / DataStream
Reporter: xuhuang
The _ProcessFunction_ requires a method to indicate that the current processing
partition has ended. This is useful in batch scenarios for outputting results
and clearing state.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
