This is an automated email from the ASF dual-hosted git repository. mergebot-role pushed a commit to branch mergebot in repository https://gitbox.apache.org/repos/asf/beam-site.git
commit cc10ea67b03501c4a07176744eab7fac03abbd1c Author: deepyaman <[email protected]> AuthorDate: Mon Sep 24 16:34:59 2018 -0400 Fix sliding time windows example documentation - Update description text and Java code because Python test snippet with 30-minute windows would be unwieldy --- src/documentation/programming-guide.md | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/src/documentation/programming-guide.md b/src/documentation/programming-guide.md index bd7c304..73ae16b 100644 --- a/src/documentation/programming-guide.md +++ b/src/documentation/programming-guide.md @@ -2312,13 +2312,13 @@ into fixed windows, each one minute in length: #### 7.3.2. Sliding time windows {#using-sliding-time-windows} The following example code shows how to apply `Window` to divide a `PCollection` -into sliding time windows. Each window is 30 minutes in length, and a new window +into sliding time windows. Each window is 30 seconds in length, and a new window begins every five seconds: ```java PCollection<String> items = ...; PCollection<String> slidingWindowedItems = items.apply( - Window.<String>into(SlidingWindows.of(Duration.standardMinutes(30)).every(Duration.standardSeconds(5)))); + Window.<String>into(SlidingWindows.of(Duration.standardSeconds(30)).every(Duration.standardSeconds(5)))); ``` ```py {% github_sample /apache/beam/blob/master/sdks/python/apache_beam/examples/snippets/snippets_test.py tag:setting_sliding_windows
