You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by da...@apache.org on 2016/10/26 04:17:48 UTC
[3/4] incubator-beam-site git commit: Enable syntax highlighting in
@tgroh's blog.
Enable syntax highlighting in @tgroh's blog.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/commit/f030e2f3
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/f030e2f3
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/diff/f030e2f3
Branch: refs/heads/asf-site
Commit: f030e2f34e906d8d3b165d23cf5119a73ddf1f8d
Parents: c99312a
Author: Frances Perry <fj...@google.com>
Authored: Thu Oct 20 22:06:38 2016 -0700
Committer: Frances Perry <fj...@google.com>
Committed: Fri Oct 21 15:38:22 2016 -0700
----------------------------------------------------------------------
_posts/2016-10-20-test-stream.md | 20 ++++++++++----------
_sass/_syntax-highlighting.scss | 2 +-
2 files changed, 11 insertions(+), 11 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/f030e2f3/_posts/2016-10-20-test-stream.md
----------------------------------------------------------------------
diff --git a/_posts/2016-10-20-test-stream.md b/_posts/2016-10-20-test-stream.md
index 2bd3e79..8b7eee7 100644
--- a/_posts/2016-10-20-test-stream.md
+++ b/_posts/2016-10-20-test-stream.md
@@ -111,7 +111,7 @@ For example, if we create a TestStream where all the data arrives before the
watermark and provide the result PCollection as input to the CalculateTeamScores
PTransform:
-```
+```java
TestStream<GameActionInfo> infos = TestStream.create(AvroCoder.of(GameActionInfo.class))
.addElements(new GameActionInfo("sky", "blue", 12, new Instant(0L)),
����������������new GameActionInfo("navy", "blue", 3, new Instant(0L)),
@@ -129,7 +129,7 @@ we can then assert that the result PCollection contains elements that arrived:
<img class="center-block" src="{{ "/images/blog/test-stream/elements-all-on-time.png" | prepend: site.baseurl }}" alt="Elements all arrive before the watermark, and are produced in the on-time pane" width="442">
-```
+```java
// Only one value is emitted for the blue team
PAssert.that(teamScores)
.inWindow(window)
@@ -145,7 +145,7 @@ of the window (shown below to the left of the red watermark), which demonstrates
the system to be on time, as it arrives before the watermark passes the end of
the window
-```
+```java
TestStream<GameActionInfo> infos = TestStream.create(AvroCoder.of(GameActionInfo.class))
.addElements(new GameActionInfo("sky", "blue", 3, new Instant(0L)),
������� new GameActionInfo("navy", "blue", 3, new Instant(0L).plus(Duration.standardMinutes(3))))
@@ -161,7 +161,7 @@ PCollection<KV<String, Integer>> teamScores = p.apply(createEvents)
<img class="center-block" src="{{ "/images/blog/test-stream/elements-unobservably-late.png" | prepend: site.baseurl }}" alt="An element arrives late, but before the watermark passes the end of the window, and is produced in the on-time pane" width="442">
-```
+```java
// Only one value is emitted for the blue team
PAssert.that(teamScores)
.inWindow(window)
@@ -175,7 +175,7 @@ By advancing the watermark farther in time before adding the late data, we can
demonstrate the triggering behavior that causes the system to emit an on-time
pane, and then after the late data arrives, a pane that refines the result.
-```
+```java
TestStream<GameActionInfo> infos = TestStream.create(AvroCoder.of(GameActionInfo.class))
.addElements(new GameActionInfo("sky", "blue", 3, new Instant(0L)),
����������new GameActionInfo("navy", "blue", 3, new Instant(0L).plus(Duration.standardMinutes(3))))
@@ -191,7 +191,7 @@ PCollection<KV<String, Integer>> teamScores = p.apply(createEvents)
<img class="center-block" src="{{ "/images/blog/test-stream/elements-observably-late.png" | prepend: site.baseurl }}" alt="Elements all arrive before the watermark, and are produced in the on-time pane" width="442">
-```
+```java
// An on-time pane is emitted with the events that arrived before the window closed
PAssert.that(teamScores)
.inOnTimePane(window)
@@ -209,7 +209,7 @@ If we push the watermark even further into the future, beyond the maximum
configured allowed lateness, we can demonstrate that the late element is dropped
by the system.
-```
+```java
TestStream<GameActionInfo> infos = TestStream.create(AvroCoder.of(GameActionInfo.class))
.addElements(new GameActionInfo("sky", "blue", 3, Duration.ZERO),
���������new GameActionInfo("navy", "blue", 3, Duration.standardMinutes(3)))
@@ -230,7 +230,7 @@ PCollection<KV<String, Integer>> teamScores = p.apply(createEvents)
<img class="center-block" src="{{ "/images/blog/test-stream/elements-droppably-late.png" | prepend: site.baseurl }}" alt="Elements all arrive before the watermark, and are produced in the on-time pane" width="442">
-```
+```java
// An on-time pane is emitted with the events that arrived before the window closed
PAssert.that(teamScores)
.inWindow(window)
@@ -245,7 +245,7 @@ triggers by advancing the processing time of the TestStream. If we add elements
to an input PCollection, occasionally advancing the processing time clock, and
apply `CalculateUserScores`
-```
+```java
TestStream.create(AvroCoder.of(GameActionInfo.class))
���.addElements(new GameActionInfo("scarlet", "red", 3, new Instant(0L)),
�������������� new GameActionInfo("scarlet", "red", 2, new Instant(0L).plus(Duration.standardMinutes(1))))
@@ -261,7 +261,7 @@ PCollection<KV<String, Integer>> userScores =
<img class="center-block" src="{{ "/images/blog/test-stream/elements-processing-speculative.png" | prepend: site.baseurl }}" alt="Elements all arrive before the watermark, and are produced in the on-time pane" width="442">
-```
+```java
PAssert.that(userScores)
.inEarlyGlobalWindowPanes()
.containsInAnyOrder(KV.of("scarlet", 5),
http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/f030e2f3/_sass/_syntax-highlighting.scss
----------------------------------------------------------------------
diff --git a/_sass/_syntax-highlighting.scss b/_sass/_syntax-highlighting.scss
index a6233bc..b5cd813 100644
--- a/_sass/_syntax-highlighting.scss
+++ b/_sass/_syntax-highlighting.scss
@@ -9,7 +9,7 @@
}
.c { color: #998; font-style: italic } // Comment
- .err { color: #a61717; background-color: #e3d2d2 } // Error
+ .err { color: #a61717 } // Error
.k { font-weight: bold } // Keyword
.o { font-weight: bold } // Operator
.cm { color: #998; font-style: italic } // Comment.Multiline