spark git commit: removed lambda from sortByKey()
Repository: spark Updated Branches: refs/heads/branch-1.6 43b72d83e -> d4cfd2acd removed lambda from sortByKey() According to the documentation the sortByKey method does not take a lambda as an argument, thus the example is flawed. Removed the argument completely as this will default to ascending sort. Author: Udo Klein Closes #10640 from udoklein/patch-1. (cherry picked from commit bd723bd53d9a28239b60939a248a4ea13340aad8) Signed-off-by: Sean Owen Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/d4cfd2ac Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/d4cfd2ac Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/d4cfd2ac Branch: refs/heads/branch-1.6 Commit: d4cfd2acd62f2b0638a1248a38263c04eaf8 Parents: 43b72d8 Author: Udo Klein Authored: Mon Jan 11 09:30:08 2016 + Committer: Sean Owen Committed: Mon Jan 11 09:30:27 2016 + -- examples/src/main/python/sort.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/spark/blob/d4cfd2ac/examples/src/main/python/sort.py -- diff --git a/examples/src/main/python/sort.py b/examples/src/main/python/sort.py index f6b0ecb..b6c2916 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() - To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
spark git commit: removed lambda from sortByKey()
Repository: spark Updated Branches: refs/heads/master f253feff6 -> bd723bd53 removed lambda from sortByKey() According to the documentation the sortByKey method does not take a lambda as an argument, thus the example is flawed. Removed the argument completely as this will default to ascending sort. Author: Udo Klein Closes #10640 from udoklein/patch-1. Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/bd723bd5 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/bd723bd5 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/bd723bd5 Branch: refs/heads/master Commit: bd723bd53d9a28239b60939a248a4ea13340aad8 Parents: f253fef Author: Udo Klein Authored: Mon Jan 11 09:30:08 2016 + Committer: Sean Owen Committed: Mon Jan 11 09:30:08 2016 + -- examples/src/main/python/sort.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/spark/blob/bd723bd5/examples/src/main/python/sort.py -- diff --git a/examples/src/main/python/sort.py b/examples/src/main/python/sort.py index f6b0ecb..b6c2916 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() - To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org
spark git commit: removed lambda from sortByKey()
Repository: spark Updated Branches: refs/heads/branch-1.5 665aa47f8 -> 0e2aa4198 removed lambda from sortByKey() According to the documentation the sortByKey method does not take a lambda as an argument, thus the example is flawed. Removed the argument completely as this will default to ascending sort. Author: Udo Klein Closes #10640 from udoklein/patch-1. (cherry picked from commit bd723bd53d9a28239b60939a248a4ea13340aad8) Signed-off-by: Sean Owen Project: http://git-wip-us.apache.org/repos/asf/spark/repo Commit: http://git-wip-us.apache.org/repos/asf/spark/commit/0e2aa419 Tree: http://git-wip-us.apache.org/repos/asf/spark/tree/0e2aa419 Diff: http://git-wip-us.apache.org/repos/asf/spark/diff/0e2aa419 Branch: refs/heads/branch-1.5 Commit: 0e2aa41988c4ae8391b48b0902badf0cda188dcc Parents: 665aa47 Author: Udo Klein Authored: Mon Jan 11 09:30:08 2016 + Committer: Sean Owen Committed: Mon Jan 11 09:30:40 2016 + -- examples/src/main/python/sort.py | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) -- http://git-wip-us.apache.org/repos/asf/spark/blob/0e2aa419/examples/src/main/python/sort.py -- diff --git a/examples/src/main/python/sort.py b/examples/src/main/python/sort.py index f6b0ecb..b6c2916 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() - To unsubscribe, e-mail: commits-unsubscr...@spark.apache.org For additional commands, e-mail: commits-h...@spark.apache.org