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 <boyu...@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;
}
}
