-
- Downloads
SPARK-1565, update examples to be used with spark-submit script.
Commit for initial feedback, basically I am curious if we should prompt user for providing args esp. when its mandatory. And can we skip if they are not ? Also few other things that did not work like `bin/spark-submit examples/target/scala-2.10/spark-examples-1.0.0-SNAPSHOT-hadoop1.0.4.jar --class org.apache.spark.examples.SparkALS --arg 100 500 10 5 2` Not all the args get passed properly, may be I have messed up something will try to sort it out hopefully. Author: Prashant Sharma <prashant.s@imaginea.com> Closes #552 from ScrapCodes/SPARK-1565/update-examples and squashes the following commits: 669dd23 [Prashant Sharma] Review comments 2727e70 [Prashant Sharma] SPARK-1565, update examples to be used with spark-submit script. (cherry picked from commit 44dd57fb) Signed-off-by:Patrick Wendell <pwendell@gmail.com>
Showing
- .gitignore 1 addition, 0 deletions.gitignore
- core/src/main/scala/org/apache/spark/SparkContext.scala 4 additions, 4 deletionscore/src/main/scala/org/apache/spark/SparkContext.scala
- examples/src/main/java/org/apache/spark/examples/JavaHdfsLR.java 7 additions, 6 deletions...s/src/main/java/org/apache/spark/examples/JavaHdfsLR.java
- examples/src/main/java/org/apache/spark/examples/JavaLogQuery.java 6 additions, 7 deletions...src/main/java/org/apache/spark/examples/JavaLogQuery.java
- examples/src/main/java/org/apache/spark/examples/JavaPageRank.java 9 additions, 6 deletions...src/main/java/org/apache/spark/examples/JavaPageRank.java
- examples/src/main/java/org/apache/spark/examples/JavaSparkPi.java 9 additions, 9 deletions.../src/main/java/org/apache/spark/examples/JavaSparkPi.java
- examples/src/main/java/org/apache/spark/examples/JavaTC.java 11 additions, 13 deletionsexamples/src/main/java/org/apache/spark/examples/JavaTC.java
- examples/src/main/java/org/apache/spark/examples/JavaWordCount.java 7 additions, 5 deletions...rc/main/java/org/apache/spark/examples/JavaWordCount.java
- examples/src/main/java/org/apache/spark/examples/mllib/JavaALS.java 11 additions, 11 deletions...rc/main/java/org/apache/spark/examples/mllib/JavaALS.java
- examples/src/main/java/org/apache/spark/examples/mllib/JavaKMeans.java 10 additions, 12 deletions...main/java/org/apache/spark/examples/mllib/JavaKMeans.java
- examples/src/main/java/org/apache/spark/examples/mllib/JavaLR.java 9 additions, 9 deletions...src/main/java/org/apache/spark/examples/mllib/JavaLR.java
- examples/src/main/java/org/apache/spark/examples/sql/JavaSparkSQL.java 3 additions, 2 deletions...main/java/org/apache/spark/examples/sql/JavaSparkSQL.java
- examples/src/main/java/org/apache/spark/examples/streaming/JavaFlumeEventCount.java 8 additions, 11 deletions.../apache/spark/examples/streaming/JavaFlumeEventCount.java
- examples/src/main/java/org/apache/spark/examples/streaming/JavaKafkaWordCount.java 14 additions, 13 deletions...g/apache/spark/examples/streaming/JavaKafkaWordCount.java
- examples/src/main/java/org/apache/spark/examples/streaming/JavaNetworkWordCount.java 12 additions, 13 deletions...apache/spark/examples/streaming/JavaNetworkWordCount.java
- examples/src/main/java/org/apache/spark/examples/streaming/JavaQueueStream.java 11 additions, 11 deletions.../org/apache/spark/examples/streaming/JavaQueueStream.java
- examples/src/main/scala/org/apache/spark/examples/BroadcastTest.scala 10 additions, 12 deletions.../main/scala/org/apache/spark/examples/BroadcastTest.scala
- examples/src/main/scala/org/apache/spark/examples/CassandraCQLTest.scala 9 additions, 10 deletions...in/scala/org/apache/spark/examples/CassandraCQLTest.scala
- examples/src/main/scala/org/apache/spark/examples/CassandraTest.scala 5 additions, 5 deletions.../main/scala/org/apache/spark/examples/CassandraTest.scala
- examples/src/main/scala/org/apache/spark/examples/ExceptionHandlingTest.scala 3 additions, 8 deletions...ala/org/apache/spark/examples/ExceptionHandlingTest.scala
Loading
Please register or sign in to comment