Skip to content

Commit 95a669b

Browse files
Adds fields to ProcessBundleRequest to prepare for future SDK skips for fetching/writing state.
1 parent f65ec40 commit 95a669b

File tree

1 file changed

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

1 file changed

+2
-2
lines changed

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

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -416,10 +416,10 @@ message ProcessBundleRequest {
416416
// at https://s.apache.org/beam-fn-api-control-data-embedding.
417417
Elements elements = 3;
418418

419-
// indicates that the runner has no start for the keys in this bundle
419+
// indicates that the runner has no stare for the keys in this bundle
420420
// so SDk can safely begin stateful processing with a locally-generated
421421
// initial empty state
422-
bool has_no_keyed_state = 4;
422+
bool has_no_state = 4;
423423

424424
// indicates that the runner will never process another bundle for the keys
425425
// in this bundle so state need not be included in the bundle commit.

0 commit comments

Comments
 (0)