aboutsummaryrefslogtreecommitdiff
path: root/core
Commit message (Expand)AuthorAgeFilesLines
* Always use a shufflePatrick Wendell2013-10-241-15/+7
* Add a `repartition` operator.Patrick Wendell2013-10-242-0/+54
* Merge pull request #93 from kayousterhout/ui_new_stateMatei Zaharia2013-10-2310-8/+130
|\
| * Clear akka frame size property in testsKay Ousterhout2013-10-231-2/+6
| * Fixed broken testsKay Ousterhout2013-10-231-4/+3
| * Merge remote-tracking branch 'upstream/master' into ui_new_stateKay Ousterhout2013-10-2344-668/+854
| |\
| * | Shorten GETTING_RESULT to GET_RESULTKay Ousterhout2013-10-221-1/+1
| * | Show "GETTING_RESULTS" state in UI.Kay Ousterhout2013-10-2110-5/+124
* | | Add unpersist() to JavaDoubleRDD and JavaPairRDD.Josh Rosen2013-10-233-0/+34
| |/ |/|
* | Remove redundant Java Function call() definitionsJosh Rosen2013-10-228-32/+4
* | Formatting cleanupPatrick Wendell2013-10-221-3/+5
* | Minor clean-up in reviewPatrick Wendell2013-10-223-8/+3
* | Response to code review and adding some more testsPatrick Wendell2013-10-2210-74/+107
* | Fix for Spark-870.Patrick Wendell2013-10-227-13/+17
* | SPARK-940: Do not directly pass Stage objects to SparkListener.Patrick Wendell2013-10-229-59/+75
* | Merge pull request #82 from JoshRosen/map-output-tracker-refactoringMatei Zaharia2013-10-225-98/+109
|\ \
| * | Unwrap a long line that actually fits.Josh Rosen2013-10-201-2/+1
| * | Fix test failures in local mode due to updateEpochJosh Rosen2013-10-201-4/+1
| * | Split MapOutputTracker into Master/Worker classes.Josh Rosen2013-10-195-98/+113
* | | Merge ShufflePerfTester patch into shuffle block consolidationAaron Davidson2013-10-2116-446/+491
|\ \ \
| * \ \ Merge pull request #95 from aarondav/perftestReynold Xin2013-10-211-0/+0
| |\ \ \
| | * | | Put StoragePerfTester in org/apache/Aaron Davidson2013-10-211-0/+0
| * | | | Fix mesos urlsAaron Davidson2013-10-211-2/+2
| |/ / /
| * | | Merge pull request #88 from rxin/cleanPatrick Wendell2013-10-217-101/+113
| |\ \ \ | | |_|/ | |/| |
| | * | Made JobLogger public again and some minor cleanup.Reynold Xin2013-10-201-68/+54
| | * | Made the following traits/interfaces/classes non-public:Reynold Xin2013-10-207-39/+65
| * | | Merge pull request #41 from pwendell/shuffle-benchmarkPatrick Wendell2013-10-206-4/+141
| |\ \ \
| | * | | Making the timing block more narrow for the syncPatrick Wendell2013-10-071-2/+2
| | * | | Minor cleanupPatrick Wendell2013-10-073-66/+45
| | * | | Perf benchmarkPatrick Wendell2013-10-071-0/+89
| | * | | Trying new approach with writesPatrick Wendell2013-10-072-7/+7
| | * | | Adding option to force sync to the filesystemPatrick Wendell2013-10-071-3/+17
| | * | | Track and report write throughput for shuffle tasks.Patrick Wendell2013-10-075-2/+57
| * | | | Merge pull request #89 from rxin/executorReynold Xin2013-10-201-20/+23
| |\ \ \ \
| | * | | | Don't setup the uncaught exception handler in local mode.Reynold Xin2013-10-201-20/+23
| | | |/ / | | |/| |
| * | | | Merge pull request #75 from JoshRosen/block-manager-cleanupMatei Zaharia2013-10-201-292/+166
| |\ \ \ \
| | * | | | Minor cleanup based on @aarondav's code review.Josh Rosen2013-10-201-11/+5
| | * | | | De-duplicate code in dropOld[Non]BroadcastBlocks.Josh Rosen2013-10-191-20/+6
| | * | | | Code de-duplication in put() and putBytes().Josh Rosen2013-10-191-140/+89
| | * | | | De-duplication in getRemote() and getRemoteBytes().Josh Rosen2013-10-191-32/+18
| | * | | | De-duplication in getLocal() and getLocalBytes().Josh Rosen2013-10-191-100/+59
| | | |_|/ | | |/| |
| * | | | Merge pull request #84 from rxin/kill1Reynold Xin2013-10-201-21/+38
| |\ \ \ \ | | |_|/ / | |/| | |
| | * | | Updated setGroupId documentation and marked dagSchedulerSource and blockManag...Reynold Xin2013-10-201-4/+4
| | * | | Added documentation for setJobGroup. Also some minor cleanup in SparkContext.Reynold Xin2013-10-191-19/+36
| * | | | Merge pull request #85 from rxin/cleanMatei Zaharia2013-10-201-0/+2
| |\ \ \ \ | | |_|/ / | |/| | |
| | * | | Moved the top level spark package object from spark to org.apache.sparkReynold Xin2013-10-191-0/+2
| | |/ /
* | | | Remove executorId from Task.run()Aaron Davidson2013-10-213-3/+3
* | | | Documentation updateAaron Davidson2013-10-201-3/+1
* | | | Close shuffle writers during failure & remove executorId from TaskContextAaron Davidson2013-10-207-15/+13
* | | | Cleanup old shuffle file metadata from memoryAaron Davidson2013-10-202-7/+13