This is an automated email from the ASF dual-hosted git repository. melap 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 84275d0 Document windowing function in seconds new 913b6f0 Merge pull request #8331: [BEAM-4373] Document windowing function in seconds 84275d0 is described below commit 84275d0dbb638e623b6855559b310ce230b9e97f Author: Cyrus Maden <cyrus_ma...@brown.edu> AuthorDate: Wed Apr 17 10:41:15 2019 -0400 Document windowing function in seconds Align windowing doc (currently documents windowing in minutes) with source code (manages windowing in seconds). Addresses https://issues.apache.org/jira/browse/BEAM-4373. Source: https://github.com/apache/beam/blob/bbabb4202cdbe234ab7be9a1cda57f0e8e226357/sdks/python/apache_beam/transforms/window.py#L378 --- website/src/documentation/programming-guide.md | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/website/src/documentation/programming-guide.md b/website/src/documentation/programming-guide.md index ab7c587..ea72a22 100644 --- a/website/src/documentation/programming-guide.md +++ b/website/src/documentation/programming-guide.md @@ -2340,12 +2340,12 @@ for more information. #### 7.3.1. Fixed-time windows {#using-fixed-time-windows} The following example code shows how to apply `Window` to divide a `PCollection` -into fixed windows, each one minute in length: +into fixed windows, each 60 seconds in length: ```java PCollection<String> items = ...; PCollection<String> fixedWindowedItems = items.apply( - Window.<String>into(FixedWindows.of(Duration.standardMinutes(1)))); + Window.<String>into(FixedWindows.of(Duration.standardSeconds(60)))); ``` ```py {% github_sample /apache/beam/blob/master/sdks/python/apache_beam/examples/snippets/snippets_test.py tag:setting_fixed_windows @@ -2372,12 +2372,12 @@ begins every five seconds: The following example code shows how to apply `Window` to divide a `PCollection` into session windows, where each session must be separated by a time gap of at -least 10 minutes: +least 10 minutes (600 seconds): ```java PCollection<String> items = ...; PCollection<String> sessionWindowedItems = items.apply( - Window.<String>into(Sessions.withGapDuration(Duration.standardMinutes(10)))); + Window.<String>into(Sessions.withGapDuration(Duration.standardSeconds(600)))); ``` ```py {% github_sample /apache/beam/blob/master/sdks/python/apache_beam/examples/snippets/snippets_test.py tag:setting_session_windows