beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From boyu...@apache.org
Subject [beam] branch master updated: Specify the time resolution for TestStreamPayload.
Date Tue, 02 Mar 2021 21:21:03 GMT
This is an automated email from the ASF dual-hosted git repository.

boyuanz 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 2d9c666  Specify the time resolution for TestStreamPayload.
     new 7e5e932  Merge pull request #14128 from Specify the time resolution for TestStreamPayload.
2d9c666 is described below

commit 2d9c66647ecbc9aca6a8618168d44e4c815cea19
Author: Boyuan Zhang <boyuanz@google.com>
AuthorDate: Tue Mar 2 10:13:34 2021 -0800

    Specify the time resolution for TestStreamPayload.
---
 model/pipeline/src/main/proto/beam_runner_api.proto | 6 +++---
 1 file changed, 3 insertions(+), 3 deletions(-)

diff --git a/model/pipeline/src/main/proto/beam_runner_api.proto b/model/pipeline/src/main/proto/beam_runner_api.proto
index 9a2075c..61b92be 100644
--- a/model/pipeline/src/main/proto/beam_runner_api.proto
+++ b/model/pipeline/src/main/proto/beam_runner_api.proto
@@ -624,7 +624,7 @@ message TestStreamPayload {
 
     // Advances the watermark to the specified timestamp.
     message AdvanceWatermark {
-      // (Required) The watermark to advance to.
+      // (Required) The watermark in millisecond to advance to.
       int64 new_watermark = 1;
 
       // (Optional) The output watermark tag for a PCollection. If unspecified
@@ -635,7 +635,7 @@ message TestStreamPayload {
 
     // Advances the processing time clock by the specified amount.
     message AdvanceProcessingTime {
-      // (Required) The duration to advance by.
+      // (Required) The duration in millisecond to advance by.
       int64 advance_duration = 1;
     }
 
@@ -657,7 +657,7 @@ message TestStreamPayload {
     // encoding primitives.
     bytes encoded_element = 1;
 
-    // (Required) The event timestamp of this element.
+    // (Required) The event timestamp in millisecond of this element.
     int64 timestamp = 2;
   }
 }


Mime
View raw message