Repository: incubator-beam-site Updated Branches: refs/heads/asf-site 59f789b97 -> a4eb4de53
[BEAM-900] Spark quickstart instructions. 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/a5dacb95 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/tree/a5dacb95 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam-site/diff/a5dacb95 Branch: refs/heads/asf-site Commit: a5dacb95d5d8dff7718a52f1a05055702742b860 Parents: 59f789b Author: Sela <[email protected]> Authored: Sat Dec 10 22:43:49 2016 +0200 Committer: Davor Bonaci <[email protected]> Committed: Sat Dec 10 13:19:50 2016 -0800 ---------------------------------------------------------------------- src/get-started/quickstart.md | 18 ++++++++++++++---- 1 file changed, 14 insertions(+), 4 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-beam-site/blob/a5dacb95/src/get-started/quickstart.md ---------------------------------------------------------------------- diff --git a/src/get-started/quickstart.md b/src/get-started/quickstart.md index 8c1d5e9..76777b0 100644 --- a/src/get-started/quickstart.md +++ b/src/get-started/quickstart.md @@ -42,7 +42,7 @@ $ mvn archetype:generate \ This will create a directory `word-count-beam` that contains a simple `pom.xml` and a series of example pipelines that count words in text files. ``` -$ cd beam-word-count/ +$ cd word-count-beam/ $ ls pom.xml src @@ -97,7 +97,8 @@ You can monitor the running job by visiting the Flink dashboard at http://<flink {:.runner-spark} ``` -TODO BEAM-900 +$ mvn compile exec:java -Dexec.mainClass=org.apache.beam.examples.WordCount \ + -Dexec.args="--runner=SparkRunner --inputFile=pom.xml --output=counts" -Pspark-runner ``` {:.runner-dataflow} @@ -134,7 +135,7 @@ $ ls /tmp/counts* {:.runner-spark} ``` -TODO BEAM-900 +$ ls counts* ``` @@ -197,7 +198,16 @@ Foundation: 1 {:.runner-spark} ``` -TODO BEAM-900 +$ more counts* +beam: 27 +SF: 1 +fat: 1 +job: 1 +limitations: 1 +require: 1 +of: 11 +profile: 10 +... ``` {:.runner-dataflow}
