diff options
| -rwxr-xr-x | examples/src/main/python/sort.py | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/examples/src/main/python/sort.py b/examples/src/main/python/sort.py index f6b0ecb02c..b6c2916254 100755 --- a/examples/src/main/python/sort.py +++ b/examples/src/main/python/sort.py @@ -30,7 +30,7 @@ if __name__ == "__main__": lines = sc.textFile(sys.argv[1], 1) sortedCount = lines.flatMap(lambda x: x.split(' ')) \ .map(lambda x: (int(x), 1)) \ - .sortByKey(lambda x: x) + .sortByKey() # This is just a demo on how to bring all the sorted data back to a single node. # In reality, we wouldn't want to collect all the data to the driver node. output = sortedCount.collect() |