[beam] branch master updated: Update beam_fn_api.proto to specify allowed split points. (#8476)

[go...@apache.org]

This is an automated email from the ASF dual-hosted git repository.

goenka 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 c6f0057  Update beam_fn_api.proto to specify allowed split points. (#8476)
c6f0057 is described below

commit c6f0057f43b03595244eb3ce019f3639691f16d7
Author: ananvay <an...@yahoo.com>
AuthorDate: Thu May 2 18:10:30 2019 -0700

    Update beam_fn_api.proto to specify allowed split points. (#8476)
    
    * Update beam_fn_api.proto to specify allowed split points.
---
 model/fn-execution/src/main/proto/beam_fn_api.proto | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

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 e96a8cc..c14fe14 100644
--- a/model/fn-execution/src/main/proto/beam_fn_api.proto
+++ b/model/fn-execution/src/main/proto/beam_fn_api.proto
@@ -470,13 +470,16 @@ message ProcessBundleSplitRequest {
     // possible and returning the remainder).
     float fraction_of_remainder = 1;
 
+    // A set of allowed element indices where the SDK may split. When this is
+    // empty, there are no constraints on where to split.
+    repeated int64 allowed_split_points = 3;
+
     // (Required for GrpcRead operations) Number of total elements expected
     // to be sent to this GrpcRead operation, required to correctly account
     // for unreceived data when determining where to split.
     int64 estimated_input_elements = 2;
 
     // TODO(SDF): Allow providing weights rather than sizes.
-    // TODO(SDF): Allow specifying allowed/preferred split points.
   }
 
   // (Required) Specifies the desired split for each transform.