aboutsummaryrefslogtreecommitdiff
path: root/docs
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2013-03-29 22:12:15 -0700
committerMatei Zaharia <matei@eecs.berkeley.edu>2013-03-29 22:12:15 -0700
commita98996d1fe88fe04f43e658c746927483158d2f9 (patch)
tree0e573095e99d29f8991216f415bda24bb8baac2f /docs
parent104c69414f2252090f647b820910b2ad16554fa0 (diff)
parent4e2c96538339e627013c8c0c58bd30494cc8d13b (diff)
downloadspark-a98996d1fe88fe04f43e658c746927483158d2f9.tar.gz
spark-a98996d1fe88fe04f43e658c746927483158d2f9.tar.bz2
spark-a98996d1fe88fe04f43e658c746927483158d2f9.zip
Merge pull request #545 from ash211/patch-1
Don't use deprecated Application in example
Diffstat (limited to 'docs')
-rw-r--r--docs/quick-start.md18
1 files changed, 10 insertions, 8 deletions
diff --git a/docs/quick-start.md b/docs/quick-start.md
index 216f7c9cc5..5c80d2ed3a 100644
--- a/docs/quick-start.md
+++ b/docs/quick-start.md
@@ -111,14 +111,16 @@ We'll create a very simple Spark job in Scala. So simple, in fact, that it's nam
import spark.SparkContext
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",
- 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()
- println("Lines with a: %s, Lines with b: %s".format(numAs, numBs))
+object SimpleJob {
+ def main(args: Array[String]) {
+ val logFile = "/var/log/syslog" // Should be some file on your system
+ val sc = new SparkContext("local", "Simple Job", "$YOUR_SPARK_HOME",
+ 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()
+ println("Lines with a: %s, Lines with b: %s".format(numAs, numBs))
+ }
}
{% endhighlight %}