Skip to content

Commit

Permalink
Merge pull request #10806 from robertwb/cleanup-protos2
Browse files Browse the repository at this point in the history
Minor FnAPI proto cleanups.
  • Loading branch information
lukecwik authored Feb 14, 2020
2 parents 290bd9f + 3ce24e7 commit 561b221
Showing 1 changed file with 2 additions and 10 deletions.
12 changes: 2 additions & 10 deletions model/fn-execution/src/main/proto/beam_fn_api.proto
Original file line number Diff line number Diff line change
Expand Up @@ -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.
Expand All @@ -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.
Expand Down

0 comments on commit 561b221

Please sign in to comment.