aboutsummaryrefslogtreecommitdiff
path: root/pyspark/examples/pi.py
diff options
context:
space:
mode:
authorJosh Rosen <joshrosen@eecs.berkeley.edu>2013-01-01 13:52:14 -0800
committerJosh Rosen <joshrosen@eecs.berkeley.edu>2013-01-01 13:52:14 -0800
commit170e451fbdd308ae77065bd9c0f2bd278abf0cb7 (patch)
treeda3df59e2262dac4b381227d5bc712502249d746 /pyspark/examples/pi.py
parent6f6a6b79c4c3f3555f8ff427c91e714d02afe8fa (diff)
downloadspark-170e451fbdd308ae77065bd9c0f2bd278abf0cb7.tar.gz
spark-170e451fbdd308ae77065bd9c0f2bd278abf0cb7.tar.bz2
spark-170e451fbdd308ae77065bd9c0f2bd278abf0cb7.zip
Minor documentation and style fixes for PySpark.
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