diff options
author | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2013-01-01 13:52:14 -0800 |
---|---|---|
committer | Josh Rosen <joshrosen@eecs.berkeley.edu> | 2013-01-01 13:52:14 -0800 |
commit | 170e451fbdd308ae77065bd9c0f2bd278abf0cb7 (patch) | |
tree | da3df59e2262dac4b381227d5bc712502249d746 /pyspark/examples/pi.py | |
parent | 6f6a6b79c4c3f3555f8ff427c91e714d02afe8fa (diff) | |
download | spark-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.py | 5 |
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 |