[
https://issues.apache.org/jira/browse/BEAM-664?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16221485#comment-16221485
]
ASF GitHub Bot commented on BEAM-664:
-------------------------------------
asfgit closed pull request #336: [BEAM-664] Update Java MinimalWordCount
instructions
URL: https://github.com/apache/beam-site/pull/336
This is a PR merged from a forked repository.
As GitHub hides the original diff on merge, it is displayed below for
the sake of provenance:
As this is a foreign pull request (from a fork), the diff is supplied
below (as it won't show otherwise due to GitHub magic):
diff --git a/src/get-started/wordcount-example.md
b/src/get-started/wordcount-example.md
index c40a2c706..8b379377a 100644
--- a/src/get-started/wordcount-example.md
+++ b/src/get-started/wordcount-example.md
@@ -50,46 +50,10 @@ input and output sources and show other best practices.
**To run this example in Java:**
-{:.runner-direct}
```
$ mvn compile exec:java
-Dexec.mainClass=org.apache.beam.examples.MinimalWordCount
```
-{:.runner-apex}
-```
-$ mvn compile exec:java
-Dexec.mainClass=org.apache.beam.examples.MinimalWordCount \
- -Dexec.args="--inputFile=pom.xml --output=counts --runner=ApexRunner"
-Papex-runner
-```
-
-{:.runner-flink-local}
-```
-$ mvn compile exec:java
-Dexec.mainClass=org.apache.beam.examples.MinimalWordCount \
- -Dexec.args="--runner=FlinkRunner --inputFile=pom.xml --output=counts"
-Pflink-runner
-```
-
-{:.runner-flink-cluster}
-```
-$ mvn package exec:java
-Dexec.mainClass=org.apache.beam.examples.MinimalWordCount \
- -Dexec.args="--runner=FlinkRunner --flinkMaster=<flink master>
--filesToStage=target/word-count-beam-bundled-0.1.jar \
- --inputFile=/path/to/quickstart/pom.xml
--output=/tmp/counts" -Pflink-runner
-
-You can monitor the running job by visiting the Flink dashboard at
http://<flink master>:8081
-```
-
-{:.runner-spark}
-```
-$ mvn compile exec:java
-Dexec.mainClass=org.apache.beam.examples.MinimalWordCount \
- -Dexec.args="--runner=SparkRunner --inputFile=pom.xml --output=counts"
-Pspark-runner
-```
-
-{:.runner-dataflow}
-```
-$ mvn compile exec:java
-Dexec.mainClass=org.apache.beam.examples.MinimalWordCount \
- -Dexec.args="--runner=DataflowRunner
--gcpTempLocation=gs://<your-gcs-bucket>/tmp \
- --inputFile=gs://apache-beam-samples/shakespeare/*
--output=gs://<your-gcs-bucket>/counts" \
- -Pdataflow-runner
-```
-
To view the full code in Java, see
**[MinimalWordCount](https://github.com/apache/beam/blob/master/examples/java/src/main/java/org/apache/beam/examples/MinimalWordCount.java).**
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> Port Dataflow SDK WordCount walkthrough to Beam site
> ----------------------------------------------------
>
> Key: BEAM-664
> URL: https://issues.apache.org/jira/browse/BEAM-664
> Project: Beam
> Issue Type: Task
> Components: website
> Reporter: Hadar Hod
> Assignee: Hadar Hod
> Fix For: Not applicable
>
>
> Port the WordCount walkthrough from Dataflow docs to Beam website.
> * Copy prose (translate from html to md, remove Dataflow references, etc)
> * Add accurate "How to Run" instructions for each of the WC examples
> * Include code snippets from real examples
--
This message was sent by Atlassian JIRA
(v6.4.14#64029)
