diff options
Diffstat (limited to 'examples/src/main/python/wordcount.py')
| -rwxr-xr-x | examples/src/main/python/wordcount.py | 6 |
1 files changed, 4 insertions, 2 deletions
diff --git a/examples/src/main/python/wordcount.py b/examples/src/main/python/wordcount.py index ae6cd13b83..7c0143607b 100755 --- a/examples/src/main/python/wordcount.py +++ b/examples/src/main/python/wordcount.py @@ -15,6 +15,8 @@ # limitations under the License. # +from __future__ import print_function + import sys from operator import add @@ -23,7 +25,7 @@ from pyspark import SparkContext if __name__ == "__main__": if len(sys.argv) != 2: - print >> sys.stderr, "Usage: wordcount <file>" + print("Usage: wordcount <file>", file=sys.stderr) exit(-1) sc = SparkContext(appName="PythonWordCount") lines = sc.textFile(sys.argv[1], 1) @@ -32,6 +34,6 @@ if __name__ == "__main__": .reduceByKey(add) output = counts.collect() for (word, count) in output: - print "%s: %i" % (word, count) + print("%s: %i" % (word, count)) sc.stop() |