[beam] branch master updated: Extend protocol in windmill.proto used by google-cloud-dataflow-java runner. (#23256)

[lc...@apache.org]

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 c51e1c278bc Extend protocol in windmill.proto used by google-cloud-dataflow-java runner. (#23256)
c51e1c278bc is described below

commit c51e1c278bc4ecea36e20d720c515e559d8aac56
Author: arne-alex <10...@users.noreply.github.com>
AuthorDate: Wed Sep 21 21:23:01 2022 +0200

    Extend protocol in windmill.proto used by google-cloud-dataflow-java runner. (#23256)
---
 .../worker/windmill/src/main/proto/windmill.proto           | 13 +++++++++++++
 1 file changed, 13 insertions(+)

diff --git a/runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto b/runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto
index c43a1f006df..b0e4dba698b 100644
--- a/runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto
+++ b/runners/google-cloud-dataflow-java/worker/windmill/src/main/proto/windmill.proto
@@ -58,6 +58,18 @@ message KeyedMessageBundle {
   repeated bytes messages_ids = 3;
 }
 
+message LatencyAttribution {
+  enum State {
+    UNKNOWN = 0;
+    QUEUED = 1;
+    ACTIVE = 2;
+    READING = 3;
+    COMMITTING = 4;
+  }
+  optional State state = 1;
+  optional int64 total_duration_millis = 2;
+}
+
 message OutputMessageBundle {
   optional string destination_computation_id = 1;
   optional string destination_stream_id = 3;
@@ -286,6 +298,7 @@ message KeyedGetDataRequest {
   // Must be at most one sorted_list_to_fetch for a given state family and tag.
   repeated TagSortedListFetchRequest sorted_lists_to_fetch = 9;
   repeated WatermarkHold watermark_holds_to_fetch = 5;
+  repeated LatencyAttribution latency_attribution = 13;
 
   optional int64 max_bytes = 7;
   reserved 4;