diff options
| author | Erik Erlandson <eerlands@redhat.com> | 2014-09-26 23:15:10 -0700 |
|---|---|---|
| committer | Reynold Xin <rxin@apache.org> | 2014-09-26 23:15:10 -0700 |
| commit | 2d972fd84ac54a89e416442508a6d4eaeff452c1 (patch) | |
| tree | 8f9203bfc245f62a983943d05f5dd190558e95cd /streaming | |
| parent | 9e8ced7847d84d63f0da08b15623d558a2407583 (diff) | |
| download | spark-2d972fd84ac54a89e416442508a6d4eaeff452c1.tar.gz spark-2d972fd84ac54a89e416442508a6d4eaeff452c1.tar.bz2 spark-2d972fd84ac54a89e416442508a6d4eaeff452c1.zip | |
[SPARK-1021] Defer the data-driven computation of partition bounds in so...
...rtByKey() until evaluation.
Author: Erik Erlandson <eerlands@redhat.com>
Closes #1689 from erikerlandson/spark-1021-pr and squashes the following commits:
50b6da6 [Erik Erlandson] use standard getIteratorSize in countAsync
4e334a9 [Erik Erlandson] exception mystery fixed by fixing bug in ComplexFutureAction
b88b5d4 [Erik Erlandson] tweak async actions to use ComplexFutureAction[T] so they handle RangePartitioner sampling job properly
b2b20e8 [Erik Erlandson] Fix bug in exception passing with ComplexFutureAction[T]
ca8913e [Erik Erlandson] RangePartition sampling job -> FutureAction
7143f97 [Erik Erlandson] [SPARK-1021] modify range bounds variable to be thread safe
ac67195 [Erik Erlandson] [SPARK-1021] Defer the data-driven computation of partition bounds in sortByKey() until evaluation.
Diffstat (limited to 'streaming')
0 files changed, 0 insertions, 0 deletions