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
