aboutsummaryrefslogtreecommitdiff
path: root/pyspark/examples/pi.py
diff options
context:
space:
mode:
Diffstat (limited to 'pyspark/examples/pi.py')
-rw-r--r--pyspark/examples/pi.py5
1 files changed, 3 insertions, 2 deletions
diff --git a/pyspark/examples/pi.py b/pyspark/examples/pi.py
index 348bbc5dce..127cba029b 100644
--- a/pyspark/examples/pi.py
+++ b/pyspark/examples/pi.py
@@ -1,13 +1,14 @@
import sys
from random import random
from operator import add
-from pyspark.context import SparkContext
+
+from pyspark import SparkContext
if __name__ == "__main__":
if len(sys.argv) == 1:
print >> sys.stderr, \
- "Usage: PythonPi <host> [<slices>]"
+ "Usage: PythonPi <master> [<slices>]"
exit(-1)
sc = SparkContext(sys.argv[1], "PythonPi")
slices = int(sys.argv[2]) if len(sys.argv) > 2 else 2