You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by me...@apache.org on 2017/08/23 22:48:47 UTC
[beam-site] 01/02: [BEAM-2780] Fix Window sample code in
programming guide
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 c425fee42717d6c9934f8290742cddd274bd10a2
Author: melissa <me...@google.com>
AuthorDate: Fri Aug 18 11:46:03 2017 -0700
[BEAM-2780] Fix Window sample code in programming guide
---
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 d7e37a0..70c3785 100644
--- a/src/documentation/programming-guide.md
+++ b/src/documentation/programming-guide.md
@@ -1672,7 +1672,7 @@ You set the trigger(s) for a `PCollection` by invoking the method `.triggering()
```java
PCollection<String> pc = ...;
- pc.apply(Window<String>.into(FixedWindows.of(1, TimeUnit.MINUTES))
+ pc.apply(Window.<String>into(FixedWindows.of(1, TimeUnit.MINUTES))
.triggering(AfterProcessingTime.pastFirstElementInPane()
.plusDelayOf(Duration.standardMinutes(1)))
.discardingFiredPanes());
@@ -1728,7 +1728,7 @@ You set the allowed lateness by using `.withAllowedLateness()` when you set your
```java
PCollection<String> pc = ...;
- pc.apply(Window<String>.into(FixedWindows.of(1, TimeUnit.MINUTES))
+ pc.apply(Window.<String>into(FixedWindows.of(1, TimeUnit.MINUTES))
.triggering(AfterProcessingTime.pastFirstElementInPane()
.plusDelayOf(Duration.standardMinutes(1)))
.withAllowedLateness(Duration.standardMinutes(30));
--
To stop receiving notification emails like this one, please contact
"commits@beam.apache.org" <co...@beam.apache.org>.