[beam] branch master updated: [BEAM-7965] add retracting mode to model proto.

[lcwik]

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 530f1d7  [BEAM-7965] add retracting mode to model proto.
     new 544604c  Merge pull request #9329 from 
amaliujia/add_retraction_in_java_sdk
530f1d7 is described below

commit 530f1d70a6b143a1f6c0e03c9a49808f2e3cedf8
Author: amaliujia <amaliu...@gmail.com>
AuthorDate: Tue Aug 13 10:27:48 2019 -0700

    [BEAM-7965] add retracting mode to model proto.
---
 model/pipeline/src/main/proto/beam_runner_api.proto | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/model/pipeline/src/main/proto/beam_runner_api.proto 
b/model/pipeline/src/main/proto/beam_runner_api.proto
index 204c408..736bcdc 100644
--- a/model/pipeline/src/main/proto/beam_runner_api.proto
+++ b/model/pipeline/src/main/proto/beam_runner_api.proto
@@ -734,6 +734,9 @@ message AccumulationMode {
 
     // The aggregation is accumulated across outputs
     ACCUMULATING = 2;
+
+    // The aggregation emits retractions when it is output
+    RETRACTING = 3;
   }
 }