beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From da...@apache.org
Subject [2/3] incubator-beam-site git commit: Regenerate website
Date Wed, 16 Nov 2016 17:36:12 GMT
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 <davor@google.com>
Authored: Wed Nov 16 09:35:38 2016 -0800
Committer: Davor Bonaci <davor@google.com>
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://&lt;flink master&gt;: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>
 


Mime
View raw message