From commits-return-113187-archive-asf-public=cust-asf.ponee.io@beam.apache.org Tue Mar 2 21:21:08 2021 Return-Path: X-Original-To: archive-asf-public@cust-asf.ponee.io Delivered-To: archive-asf-public@cust-asf.ponee.io Received: from mxout1-ec2-va.apache.org (mxout1-ec2-va.apache.org [3.227.148.255]) by mx-eu-01.ponee.io (Postfix) with ESMTPS id 49509180630 for ; Tue, 2 Mar 2021 22:21:08 +0100 (CET) Received: from mail.apache.org (mailroute1-lw-us.apache.org [207.244.88.153]) by mxout1-ec2-va.apache.org (ASF Mail Server at mxout1-ec2-va.apache.org) with SMTP id 7CF0B432B1 for ; Tue, 2 Mar 2021 21:21:07 +0000 (UTC) Received: (qmail 3629 invoked by uid 500); 2 Mar 2021 21:21:07 -0000 Mailing-List: contact commits-help@beam.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@beam.apache.org Delivered-To: mailing list commits@beam.apache.org Received: (qmail 3619 invoked by uid 99); 2 Mar 2021 21:21:07 -0000 Received: from ec2-52-202-80-70.compute-1.amazonaws.com (HELO gitbox.apache.org) (52.202.80.70) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 02 Mar 2021 21:21:07 +0000 Received: by gitbox.apache.org (ASF Mail Server at gitbox.apache.org, from userid 33) id C9E92816A5; Tue, 2 Mar 2021 21:21:06 +0000 (UTC) Date: Tue, 02 Mar 2021 21:21:03 +0000 To: "commits@beam.apache.org" Subject: [beam] branch master updated: Specify the time resolution for TestStreamPayload. MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 8bit Message-ID: <161472005909.16805.53470688608600979@gitbox.apache.org> From: boyuanz@apache.org X-Git-Host: gitbox.apache.org X-Git-Repo: beam X-Git-Refname: refs/heads/master X-Git-Reftype: branch X-Git-Oldrev: 1f35e2fae03c129bad479eee54f6f27c510264a9 X-Git-Newrev: 2d9c66647ecbc9aca6a8618168d44e4c815cea19 X-Git-Rev: 2d9c66647ecbc9aca6a8618168d44e4c815cea19 X-Git-NotificationType: ref_changed_plus_diff X-Git-Multimail-Version: 1.5.dev Auto-Submitted: auto-generated 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 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; } }