This is an automated email from the ASF dual-hosted git repository.
kenn pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
The following commit(s) were added to refs/heads/master by this push:
new 3721c17265e Adds proto fields for overwriting fetch/write state
functionality (#36708)
3721c17265e is described below
commit 3721c17265e86346fb1671af8083ceb6df12e3dd
Author: wolfchris-google <[email protected]>
AuthorDate: Mon Nov 17 17:57:25 2025 +0000
Adds proto fields for overwriting fetch/write state functionality (#36708)
---
.../org/apache/beam/model/fn_execution/v1/beam_fn_api.proto | 9 +++++++++
1 file changed, 9 insertions(+)
diff --git
a/model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto
b/model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto
index 4eee2ef5d89..4d907f2ac72 100644
---
a/model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto
+++
b/model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto
@@ -415,6 +415,15 @@ message ProcessBundleRequest {
// beam:protocol:control_request_elements_embedding:v1 capability. See more
// at https://s.apache.org/beam-fn-api-control-data-embedding.
Elements elements = 3;
+
+ // indicates that the runner has no stare for the keys in this bundle
+ // so SDk can safely begin stateful processing with a locally-generated
+ // initial empty state
+ bool has_no_state = 4;
+
+ // indicates that the runner will never process another bundle for the keys
+ // in this bundle so state need not be included in the bundle commit.
+ bool only_bundle_for_keys = 5;
}
message ProcessBundleResponse {
