Skip to content

Commit 3721c17

Browse files
Adds proto fields for overwriting fetch/write state functionality (#36708)
1 parent 53a0d3c commit 3721c17

File tree

1 file changed

+9
-0
lines changed
  • model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1

1 file changed

+9
-0
lines changed

model/fn-execution/src/main/proto/org/apache/beam/model/fn_execution/v1/beam_fn_api.proto

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -415,6 +415,15 @@ message ProcessBundleRequest {
415415
// beam:protocol:control_request_elements_embedding:v1 capability. See more
416416
// at https://s.apache.org/beam-fn-api-control-data-embedding.
417417
Elements elements = 3;
418+
419+
// indicates that the runner has no stare for the keys in this bundle
420+
// so SDk can safely begin stateful processing with a locally-generated
421+
// initial empty state
422+
bool has_no_state = 4;
423+
424+
// indicates that the runner will never process another bundle for the keys
425+
// in this bundle so state need not be included in the bundle commit.
426+
bool only_bundle_for_keys = 5;
418427
}
419428

420429
message ProcessBundleResponse {

0 commit comments

Comments
 (0)