aboutsummaryrefslogtreecommitdiff
path: root/examples/src/main/scala
diff options
context:
space:
mode:
authorMatei Zaharia <matei@eecs.berkeley.edu>2012-09-25 19:31:07 -0700
committerMatei Zaharia <matei@eecs.berkeley.edu>2012-09-25 19:31:07 -0700
commit56c90485fd947d75bbe7aac81593ba42cfe56821 (patch)
tree99c5bc617a350a408abfa62f612fc14c807ad1e7 /examples/src/main/scala
parent1821bf1f1f50e5eb1c7adf9d010ecc392b1adad5 (diff)
downloadspark-56c90485fd947d75bbe7aac81593ba42cfe56821.tar.gz
spark-56c90485fd947d75bbe7aac81593ba42cfe56821.tar.bz2
spark-56c90485fd947d75bbe7aac81593ba42cfe56821.zip
More updates to documentation
Diffstat (limited to 'examples/src/main/scala')
-rw-r--r--examples/src/main/scala/spark/examples/BroadcastTest.scala2
-rw-r--r--examples/src/main/scala/spark/examples/ExceptionHandlingTest.scala2
-rw-r--r--examples/src/main/scala/spark/examples/GroupByTest.scala2
-rw-r--r--examples/src/main/scala/spark/examples/MultiBroadcastTest.scala2
-rw-r--r--examples/src/main/scala/spark/examples/SimpleSkewedGroupByTest.scala2
-rw-r--r--examples/src/main/scala/spark/examples/SkewedGroupByTest.scala2
-rw-r--r--examples/src/main/scala/spark/examples/SparkALS.scala2
-rw-r--r--examples/src/main/scala/spark/examples/SparkLR.scala2
-rw-r--r--examples/src/main/scala/spark/examples/SparkPi.scala2
-rw-r--r--examples/src/main/scala/spark/examples/SparkTC.scala2
10 files changed, 10 insertions, 10 deletions
diff --git a/examples/src/main/scala/spark/examples/BroadcastTest.scala b/examples/src/main/scala/spark/examples/BroadcastTest.scala
index 4a560131e3..08be49a41c 100644
--- a/examples/src/main/scala/spark/examples/BroadcastTest.scala
+++ b/examples/src/main/scala/spark/examples/BroadcastTest.scala
@@ -5,7 +5,7 @@ import spark.SparkContext
object BroadcastTest {
def main(args: Array[String]) {
if (args.length == 0) {
- System.err.println("Usage: BroadcastTest <host> [<slices>] [numElem]")
+ System.err.println("Usage: BroadcastTest <master> [<slices>] [numElem]")
System.exit(1)
}
diff --git a/examples/src/main/scala/spark/examples/ExceptionHandlingTest.scala b/examples/src/main/scala/spark/examples/ExceptionHandlingTest.scala
index 90941ddbf0..c89f3dac0c 100644
--- a/examples/src/main/scala/spark/examples/ExceptionHandlingTest.scala
+++ b/examples/src/main/scala/spark/examples/ExceptionHandlingTest.scala
@@ -5,7 +5,7 @@ import spark.SparkContext
object ExceptionHandlingTest {
def main(args: Array[String]) {
if (args.length == 0) {
- System.err.println("Usage: ExceptionHandlingTest <host>")
+ System.err.println("Usage: ExceptionHandlingTest <master>")
System.exit(1)
}
diff --git a/examples/src/main/scala/spark/examples/GroupByTest.scala b/examples/src/main/scala/spark/examples/GroupByTest.scala
index 9d11692aeb..86dfba3a40 100644
--- a/examples/src/main/scala/spark/examples/GroupByTest.scala
+++ b/examples/src/main/scala/spark/examples/GroupByTest.scala
@@ -7,7 +7,7 @@ import java.util.Random
object GroupByTest {
def main(args: Array[String]) {
if (args.length == 0) {
- System.err.println("Usage: GroupByTest <host> [numMappers] [numKVPairs] [KeySize] [numReducers]")
+ System.err.println("Usage: GroupByTest <master> [numMappers] [numKVPairs] [KeySize] [numReducers]")
System.exit(1)
}
diff --git a/examples/src/main/scala/spark/examples/MultiBroadcastTest.scala b/examples/src/main/scala/spark/examples/MultiBroadcastTest.scala
index 240376da90..83ae014e94 100644
--- a/examples/src/main/scala/spark/examples/MultiBroadcastTest.scala
+++ b/examples/src/main/scala/spark/examples/MultiBroadcastTest.scala
@@ -5,7 +5,7 @@ import spark.SparkContext
object MultiBroadcastTest {
def main(args: Array[String]) {
if (args.length == 0) {
- System.err.println("Usage: BroadcastTest <host> [<slices>] [numElem]")
+ System.err.println("Usage: BroadcastTest <master> [<slices>] [numElem]")
System.exit(1)
}
diff --git a/examples/src/main/scala/spark/examples/SimpleSkewedGroupByTest.scala b/examples/src/main/scala/spark/examples/SimpleSkewedGroupByTest.scala
index c44b42c5b6..50b3a263b4 100644
--- a/examples/src/main/scala/spark/examples/SimpleSkewedGroupByTest.scala
+++ b/examples/src/main/scala/spark/examples/SimpleSkewedGroupByTest.scala
@@ -7,7 +7,7 @@ import java.util.Random
object SimpleSkewedGroupByTest {
def main(args: Array[String]) {
if (args.length == 0) {
- System.err.println("Usage: SimpleSkewedGroupByTest <host> " +
+ System.err.println("Usage: SimpleSkewedGroupByTest <master> " +
"[numMappers] [numKVPairs] [valSize] [numReducers] [ratio]")
System.exit(1)
}
diff --git a/examples/src/main/scala/spark/examples/SkewedGroupByTest.scala b/examples/src/main/scala/spark/examples/SkewedGroupByTest.scala
index 9fad7ab2e5..d2117a263e 100644
--- a/examples/src/main/scala/spark/examples/SkewedGroupByTest.scala
+++ b/examples/src/main/scala/spark/examples/SkewedGroupByTest.scala
@@ -7,7 +7,7 @@ import java.util.Random
object SkewedGroupByTest {
def main(args: Array[String]) {
if (args.length == 0) {
- System.err.println("Usage: GroupByTest <host> [numMappers] [numKVPairs] [KeySize] [numReducers]")
+ System.err.println("Usage: GroupByTest <master> [numMappers] [numKVPairs] [KeySize] [numReducers]")
System.exit(1)
}
diff --git a/examples/src/main/scala/spark/examples/SparkALS.scala b/examples/src/main/scala/spark/examples/SparkALS.scala
index 59d5154e08..fb28e2c932 100644
--- a/examples/src/main/scala/spark/examples/SparkALS.scala
+++ b/examples/src/main/scala/spark/examples/SparkALS.scala
@@ -107,7 +107,7 @@ object SparkALS {
host = host_
}
case _ => {
- System.err.println("Usage: SparkALS <M> <U> <F> <iters> <slices> <host>")
+ System.err.println("Usage: SparkALS <M> <U> <F> <iters> <slices> <master>")
System.exit(1)
}
}
diff --git a/examples/src/main/scala/spark/examples/SparkLR.scala b/examples/src/main/scala/spark/examples/SparkLR.scala
index 6777b471fb..aaaf062c8f 100644
--- a/examples/src/main/scala/spark/examples/SparkLR.scala
+++ b/examples/src/main/scala/spark/examples/SparkLR.scala
@@ -25,7 +25,7 @@ object SparkLR {
def main(args: Array[String]) {
if (args.length == 0) {
- System.err.println("Usage: SparkLR <host> [<slices>]")
+ System.err.println("Usage: SparkLR <master> [<slices>]")
System.exit(1)
}
val sc = new SparkContext(args(0), "SparkLR")
diff --git a/examples/src/main/scala/spark/examples/SparkPi.scala b/examples/src/main/scala/spark/examples/SparkPi.scala
index 751fef6ab0..2f226f1380 100644
--- a/examples/src/main/scala/spark/examples/SparkPi.scala
+++ b/examples/src/main/scala/spark/examples/SparkPi.scala
@@ -7,7 +7,7 @@ import SparkContext._
object SparkPi {
def main(args: Array[String]) {
if (args.length == 0) {
- System.err.println("Usage: SparkPi <host> [<slices>]")
+ System.err.println("Usage: SparkPi <master> [<slices>]")
System.exit(1)
}
val spark = new SparkContext(args(0), "SparkPi")
diff --git a/examples/src/main/scala/spark/examples/SparkTC.scala b/examples/src/main/scala/spark/examples/SparkTC.scala
index a6e4de4671..90bae011ad 100644
--- a/examples/src/main/scala/spark/examples/SparkTC.scala
+++ b/examples/src/main/scala/spark/examples/SparkTC.scala
@@ -26,7 +26,7 @@ object SparkTC {
def main(args: Array[String]) {
if (args.length == 0) {
- System.err.println("Usage: SparkTC <host> [<slices>]")
+ System.err.println("Usage: SparkTC <master> [<slices>]")
System.exit(1)
}
val spark = new SparkContext(args(0), "SparkTC")