You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ke...@apache.org on 2025/11/17 17:57:34 UTC
(beam) branch master updated: Adds proto fields for overwriting fetch/write state functionality (#36708)
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 <wo...@google.com>
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 {