diff options
| author | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-11-28 22:59:28 -0800 |
|---|---|---|
| committer | Matei Zaharia <matei@eecs.berkeley.edu> | 2012-11-28 22:59:28 -0800 |
| commit | 8d3713c22180e9a7f190549c2b94ac058c07130a (patch) | |
| tree | 7d318b4fe2b2482359e7ed6ee3b182f30072cd8c | |
| parent | f86960cba91bfa558785b93047f7573d7d8b9e28 (diff) | |
| parent | 6ceb5599944449f3037bed538bd7b5b472043440 (diff) | |
| download | spark-8d3713c22180e9a7f190549c2b94ac058c07130a.tar.gz spark-8d3713c22180e9a7f190549c2b94ac058c07130a.tar.bz2 spark-8d3713c22180e9a7f190549c2b94ac058c07130a.zip | |
Merge pull request #314 from pwendell/quickstart-bugfix
Adding multi-jar constructor in quickstart
| -rw-r--r-- | docs/quick-start.md | 4 |
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>() { |