This is an automated email from the ASF dual-hosted git repository.
lcwik 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 3ce24e7 Minor FnAPI proto cleanups.
new 561b221 Merge pull request #10806 from robertwb/cleanup-protos2
3ce24e7 is described below
commit 3ce24e73c4d6d39c29dcb376514373414c307b31
Author: Robert Bradshaw <rober...@gmail.com>
AuthorDate: Fri Feb 7 17:51:27 2020 -0800
Minor FnAPI proto cleanups.
* Don't require is_bounded on BundleApplication, as the default
is the same as unknown.
* Remove monitoring_infos from BundleApplication, as sizing information
is now encoded in the element value.
* Update the note on the UserState flag to indicate it applies to all
user state.
---
model/fn-execution/src/main/proto/beam_fn_api.proto | 12 ++----------
1 file changed, 2 insertions(+), 10 deletions(-)
diff --git a/model/fn-execution/src/main/proto/beam_fn_api.proto
b/model/fn-execution/src/main/proto/beam_fn_api.proto
index 9678966..4bf1a39 100644
--- a/model/fn-execution/src/main/proto/beam_fn_api.proto
+++ b/model/fn-execution/src/main/proto/beam_fn_api.proto
@@ -189,18 +189,10 @@ message BundleApplication {
// use MIN_TIMESTAMP by default.
map<string, google.protobuf.Timestamp> output_watermarks = 4;
- // (Required) Whether this application potentially produces an unbounded
+ // Whether this application potentially produces an unbounded
// amount of data. Note that this should only be set to BOUNDED if and
// only if the application is known to produce a finite amount of output.
org.apache.beam.model.pipeline.v1.IsBounded.Enum is_bounded = 5;
-
- // Contains additional monitoring information related to this application.
- //
- // Each application is able to report information that some runners
- // will use when providing a UI or for making scaling and performance
- // decisions. See https://s.apache.org/beam-bundles-backlog-splitting for
- // details about what types of signals may be useful to report.
- repeated org.apache.beam.model.pipeline.v1.MonitoringInfo monitoring_infos =
6;
}
// An Application should be scheduled for execution after a delay.
@@ -227,7 +219,7 @@ message ProcessBundleRequest {
// of cached elements which have a cache token associated.
message CacheToken {
- // A flag to indicate a cache token is valid for user state.
+ // A flag to indicate a cache token is valid for all user state.
message UserState {}
// A flag to indicate a cache token is valid for a side input.
