This is an automated email from the ASF dual-hosted git repository. altay pushed a commit to branch asf-site in repository https://gitbox.apache.org/repos/asf/beam-site.git
commit fa66528c45235d3ef73566e46ac8baa98cda8dae Author: Alex Filatov <alex-fila...@users.noreply.github.com> AuthorDate: Thu Oct 19 17:44:18 2017 +0300 [BEAM-664] Update docs: MinimalWordCount in Java is intentionally hardcoded to run only on DirectRunner --- src/get-started/wordcount-example.md | 36 ------------------------------------ 1 file changed, 36 deletions(-) diff --git a/src/get-started/wordcount-example.md b/src/get-started/wordcount-example.md index c40a2c7..8b37937 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).** -- To stop receiving notification emails like this one, please contact "commits@beam.apache.org" <commits@beam.apache.org>.