aboutsummaryrefslogtreecommitdiff
path: root/docs/quick-start.md
diff options
context:
space:
mode:
authorPatrick Wendell <pwendell@gmail.com>2012-11-27 23:30:10 -0800
committerPatrick Wendell <pwendell@gmail.com>2012-11-27 23:32:24 -0800
commit6ceb5599944449f3037bed538bd7b5b472043440 (patch)
tree7d318b4fe2b2482359e7ed6ee3b182f30072cd8c /docs/quick-start.md
parentf86960cba91bfa558785b93047f7573d7d8b9e28 (diff)
downloadspark-6ceb5599944449f3037bed538bd7b5b472043440.tar.gz
spark-6ceb5599944449f3037bed538bd7b5b472043440.tar.bz2
spark-6ceb5599944449f3037bed538bd7b5b472043440.zip
Adding multi-jar constructor in quickstart
Diffstat (limited to 'docs/quick-start.md')
-rw-r--r--docs/quick-start.md4
1 files changed, 2 insertions, 2 deletions
diff --git a/docs/quick-start.md b/docs/quick-start.md
index dbc232b6e0..177cb14551 100644
--- a/docs/quick-start.md
+++ b/docs/quick-start.md
@@ -113,7 +113,7 @@ import SparkContext._
object SimpleJob extends Application {
val logFile = "/var/log/syslog" // Should be some file on your system
val sc = new SparkContext("local", "Simple Job", "$YOUR_SPARK_HOME",
- "target/scala-{{site.SCALA_VERSION}}/simple-project_{{site.SCALA_VERSION}}-1.0.jar")
+ List("target/scala-{{site.SCALA_VERSION}}/simple-project_{{site.SCALA_VERSION}}-1.0.jar"))
val logData = sc.textFile(logFile, 2).cache()
val numAs = logData.filter(line => line.contains("a")).count()
val numBs = logData.filter(line => line.contains("b")).count()
@@ -172,7 +172,7 @@ public class SimpleJob {
public static void main(String[] args) {
String logFile = "/var/log/syslog"; // Should be some file on your system
JavaSparkContext sc = new JavaSparkContext("local", "Simple Job",
- "$YOUR_SPARK_HOME", "target/simple-project-1.0.jar");
+ "$YOUR_SPARK_HOME", new String[]{"target/simple-project-1.0.jar"});
JavaRDD<String> logData = sc.textFile(logFile).cache();
long numAs = logData.filter(new Function<String, Boolean>() {