Regenerate website
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/bfbd64c3 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/bfbd64c3 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/diff/bfbd64c3 Branch: refs/heads/asf-site Commit: bfbd64c327b3aea2bc02f5c1f829f6fc1229e703 Parents: a53e4d8 Author: Davor Bonaci <[email protected]> Authored: Wed Nov 16 09:35:38 2016 -0800 Committer: Davor Bonaci <[email protected]> Committed: Wed Nov 16 09:35:38 2016 -0800 ---------------------------------------------------------------------- content/get-started/quickstart/index.html | 42 ++++++++++++++++++++++++-- 1 file changed, 39 insertions(+), 3 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/bfbd64c3/content/get-started/quickstart/index.html ---------------------------------------------------------------------- diff --git a/content/get-started/quickstart/index.html b/content/get-started/quickstart/index.html index 1ef229a..92176b5 100644 --- a/content/get-started/quickstart/index.html +++ b/content/get-started/quickstart/index.html @@ -222,7 +222,19 @@ MinimalWordCount.java WordCount.java </code></pre> </div> -<div class="runner-flink highlighter-rouge"><pre class="highlight"><code>TODO BEAM-899 +<div class="runner-flink-local highlighter-rouge"><pre class="highlight"><code>$ mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount \ + -Dexec.args="--runner=FlinkRunner --inputFile=pom.xml --output=counts" -Pflink-runner +</code></pre> +</div> + +<div class="runner-flink-cluster highlighter-rouge"><pre class="highlight"><code>$ mvn package -Pflink-runner +$ cp target/word-count-beam-bundled-0.1.jar /path/to/flink/lib/ +$ bin/flink run -c org.apache.beam.examples.WordCount lib/word-count-beam-0.1.jar \ + --inputFile=/path/to/quickstart/pom.xml \ + --output=/tmp/counts \ + --runner=org.apache.beam.runners.flink.FlinkRunner + +You can monitor the running job by visiting the Flink dashboard at http://<flink master>:8081 </code></pre> </div> @@ -248,7 +260,11 @@ MinimalWordCount.java WordCount.java </code></pre> </div> -<div class="runner-flink highlighter-rouge"><pre class="highlight"><code>TODO BEAM-899 +<div class="runner-flink-local highlighter-rouge"><pre class="highlight"><code>$ ls counts* +</code></pre> +</div> + +<div class="runner-flink-cluster highlighter-rouge"><pre class="highlight"><code>$ ls /tmp/counts* </code></pre> </div> @@ -284,7 +300,27 @@ PAssert: 1 </code></pre> </div> -<div class="runner-flink highlighter-rouge"><pre class="highlight"><code>TODO BEAM-899 +<div class="runner-flink-local highlighter-rouge"><pre class="highlight"><code>$ more counts* +The: 1 +api: 9 +old: 4 +Apache: 2 +limitations: 1 +bundled: 1 +Foundation: 1 +... +</code></pre> +</div> + +<div class="runner-flink-cluster highlighter-rouge"><pre class="highlight"><code>$ more /tmp/counts* +The: 1 +api: 9 +old: 4 +Apache: 2 +limitations: 1 +bundled: 1 +Foundation: 1 +... </code></pre> </div>
