Simple example of spark application.
To build, use maven.
$ mvn clean package -DskipTests
modules
- example
Run application locally on 4 cores
$ bin/spark-sumbit \
--class com.nexr.spark.simpleapp.SparkPiApp \
--master local[4] \
/path/to/spark-app/example/target/example-0.9-SNAPSHOT.jar 100
Run application on cluster (standalone or yarn)
$ bin/spark-submit \
--master yarn-cluster \
--class com.nexr.spark.WordCount example-0.9-SNAPSHOT.jar