Skip to content

denisecase/java-word-count-beam

Repository files navigation

#word-count-beam

Java Quickstart for Apache Beam

https://beam.apache.org/get-started/quickstart-java

Set up Environment

  • Java
  • Maven

Get the Sample Project

mvn archetype:generate `
 -D archetypeGroupId=org.apache.beam `
 -D archetypeArtifactId=beam-sdks-java-maven-archetypes-examples `
 -D archetypeVersion=2.36.0 `
 -D groupId=org.example `
 -D artifactId=word-count-beam `
 -D version="0.1" `
 -D package=org.apache.beam.examples `
 -D interactiveMode=false`

Execute using DirectRunner

mvn compile exec:java -D exec.mainClass=org.apache.beam.examples.WordCount `
 -D exec.args="--inputFile=sample.txt --output=counts" -P direct-runner

Execute PR Quick Start

mvn compile exec:java -D exec.mainClass=org.apache.beam.examples.MinimalPageRankCase 

About

Apache Beam with Java

Resources

Stars

Watchers

Forks

Releases

No releases published

Packages

 
 
 

Contributors

Languages