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 {