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 <meliss...@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" <commits@beam.apache.org>.