aboutsummaryrefslogtreecommitdiff
path: root/core
Commit message (Expand)AuthorAgeFilesLines
...
| * | | | | refactored _With API and added foreachPartitionMark Hamstra2013-03-102-56/+57
| * | | | | Merge branch 'master' of https://github.com/mesos/spark into WithThingMark Hamstra2013-03-1014-556/+312
| |\ \ \ \ \
| * | | | | | refactor mapWith, flatMapWith and filterWith to each use two parameter listsMark Hamstra2013-03-052-12/+12
| * | | | | | whitespace formattingMark Hamstra2013-03-052-16/+16
| * | | | | | mapWith, flatMapWith and filterWithMark Hamstra2013-03-042-1/+124
* | | | | | | Merge pull request #538 from rxin/cogroupMatei Zaharia2013-03-202-9/+66
|\ \ \ \ \ \ \ | |_|_|_|_|_|/ |/| | | | | |
| * | | | | | Merge branch 'master' of github.com:mesos/spark into cogroupReynold Xin2013-03-204-13/+20
| |\ \ \ \ \ \
| * | | | | | | Added mapSideCombine flag to CoGroupedRDD. Added unit test forReynold Xin2013-03-202-9/+66
| | |_|_|_|/ / | |/| | | | |
* | | | | | | Merge pull request #526 from markhamstra/foldByKeyMatei Zaharia2013-03-203-0/+73
|\ \ \ \ \ \ \ | |_|/ / / / / |/| | | | | |
| * | | | | | whitespaceMark Hamstra2013-03-161-1/+0
| * | | | | | refactor foldByKey to use combineByKeyMark Hamstra2013-03-162-7/+19
| * | | | | | Merge branch 'master' of https://github.com/mesos/spark into foldByKeyMark Hamstra2013-03-164-40/+91
| |\| | | | |
| * | | | | | Merge branch 'master' of https://github.com/mesos/spark into foldByKeyMark Hamstra2013-03-159-13/+109
| |\ \ \ \ \ \
| * | | | | | | whitespace cleanupMark Hamstra2013-03-151-22/+22
| * | | | | | | Fuller implementation of foldByKeyMark Hamstra2013-03-152-2/+29
| * | | | | | | restrict V type of foldByKey in order to retain ClassManifest; added foldByKe...Mark Hamstra2013-03-143-3/+31
| * | | | | | | added foldByKeyMark Hamstra2013-03-141-0/+7
* | | | | | | | Merge pull request #536 from sasurfer/masterMatei Zaharia2013-03-191-2/+2
|\ \ \ \ \ \ \ \
| * | | | | | | | CoalescedRDD changed to work with a big number of partitions both in the orig...Giovanni Delussu2013-03-191-2/+2
| | |_|/ / / / / | |/| | | | | |
* | | | | | | | Merge pull request #534 from stephenh/removetrycatchMatei Zaharia2013-03-191-10/+4
|\ \ \ \ \ \ \ \
| * | | | | | | | Remove try/catch block that can't be hit.Stephen Haberman2013-03-181-10/+4
| | |_|_|_|/ / / | |/| | | | | |
* | | | | | | | call setConf from input format if it is ConfigurableAndrey Kouznetsov2013-03-192-1/+14
| |/ / / / / / |/| | | | | |
* | | | | | | Merge pull request #525 from stephenh/subtractByKeyMatei Zaharia2013-03-164-40/+91
|\ \ \ \ \ \ \ | |_|_|/ / / / |/| | | | | |
| * | | | | | Fix tabs that snuck in.Stephen Haberman2013-03-141-8/+8
| * | | | | | Allow subtractByKey's other argument to have a different value type.Stephen Haberman2013-03-143-8/+8
| * | | | | | Finished subtractByKeys.Stephen Haberman2013-03-144-23/+62
| * | | | | | Simplify SubtractedRDD in preparation from subtractByKey.Stephen Haberman2013-03-133-46/+58
| |/ / / / /
* | | | | | Merge pull request #516 from squito/fix_local_metricsMatei Zaharia2013-03-158-12/+104
|\ \ \ \ \ \
| * | | | | | increase sleep timeImran Rashid2013-03-101-1/+1
| * | | | | | add a small wait to one task to make sure some task runtime really is non-zeroImran Rashid2013-03-101-4/+10
| * | | | | | enable task metrics in local mode, add testsImran Rashid2013-03-092-2/+88
| * | | | | | rename remoteFetchWaitTime to fetchWaitTime, since it also includes time from...Imran Rashid2013-03-096-10/+10
| | |_|/ / / | |/| | | |
* | | | | | Add a log4j compile dependency to fix build in IntelliJMikhail Bautin2013-03-151-1/+5
| |_|/ / / |/| | | |
* | | | | Merge pull request #521 from stephenh/earlycloseMatei Zaharia2013-03-134-51/+153
|\ \ \ \ \ | |_|_|/ / |/| | | |
| * | | | Add a test for NextIterator.Stephen Haberman2013-03-131-0/+68
| * | | | Add NextIterator.closeIfNeeded.Stephen Haberman2013-03-132-2/+16
| * | | | Remove NextIterator.close default implementation.Stephen Haberman2013-03-122-4/+7
| * | | | More quickly call close in HadoopRDD.Stephen Haberman2013-03-113-52/+69
| | |/ / | |/| |
* / | | Send block sizes as longs.Charles Reiss2013-03-111-4/+4
|/ / /
* | | Merge remote-tracking branch 'woggling/dag-sched-driver-port'Matei Zaharia2013-03-101-5/+4
|\ \ \
| * | | Prevent DAGSchedulerSuite from corrupting driver.port.Charles Reiss2013-03-091-4/+5
| |/ /
* | | Merge pull request #512 from patelh/fix-kryo-serializerMatei Zaharia2013-03-102-11/+19
|\ \ \
| * | | Fix reference bug in Kryo serializer, add test, update versionHiral Patel2013-03-072-11/+19
| |/ /
* | | Merge pull request #515 from woggling/deploy-app-deathMatei Zaharia2013-03-103-7/+17
|\ \ \
| * | | Notify standalone deploy client of application death.Charles Reiss2013-03-093-7/+17
| |/ /
* | | Merge remote-tracking branch 'stephenh/nomocks'Matei Zaharia2013-03-109-536/+275
|\ \ \ | |/ / |/| |
| * | Fix MapOutputTrackerSuite.Stephen Haberman2013-02-261-2/+4
| * | Override DAGScheduler.runLocally so we can remove the Thread.sleep.Stephen Haberman2013-02-252-19/+27
| * | Merge branch 'master' into nomocksStephen Haberman2013-02-2595-890/+1411
| |\|
| * | Use stubs instead of mocks for DAGSchedulerSuite.Stephen Haberman2013-02-098-527/+253