aboutsummaryrefslogtreecommitdiff
path: root/core
Commit message (Collapse)AuthorAgeFilesLines
* Merge pull request #854 from markhamstra/pomUpdateMatei Zaharia2013-08-221-0/+4
|\ | | | | Synced sbt and maven builds to use the same dependencies, etc.
| * Synced sbt and maven buildsMark Hamstra2013-08-211-0/+4
| |
* | Merge pull request #832 from alig/coalesceMatei Zaharia2013-08-224-46/+389
|\ \ | |/ |/| Coalesced RDD with locality
| * Merged in from upstream to use TaskLocation instead of stringsAli Ghodsi2013-08-202-8/+11
| |
| * added curly braces to make the code more consistentAli Ghodsi2013-08-201-1/+2
| |
| * indentAli Ghodsi2013-08-201-1/+1
| |
| * Bug in test fixedAli Ghodsi2013-08-201-3/+3
| |
| * Added a test to make sure no locality preferences are ignoredAli Ghodsi2013-08-201-0/+5
| |
| * Simpler codeAli Ghodsi2013-08-202-5/+4
| |
| * simpler codeAli Ghodsi2013-08-201-16/+7
| |
| * Fixed almost all of Matei's feedbackAli Ghodsi2013-08-202-31/+26
| |
| * fixed Matei's commentsAli Ghodsi2013-08-203-73/+99
| |
| * making CoalescedRDDPartition publicAli Ghodsi2013-08-201-2/+1
| |
| * comment in the test to make it more understandableAli Ghodsi2013-08-201-1/+1
| |
| * Coalescer now uses current preferred locations for derived RDDs. Made run() ↵Ali Ghodsi2013-08-204-34/+59
| | | | | | | | in DAGScheduler thread safe and added a method to be able to ask it for preferred locations. Added a similar method that wraps the former inside SparkContext.
| * added one test that will test a future functionalityAli Ghodsi2013-08-201-1/+10
| |
| * Added error messages to the tests to make failed tests less crypticAli Ghodsi2013-08-201-7/+7
| |
| * fixed matei's commentsAli Ghodsi2013-08-201-15/+16
| |
| * Made a function object that returns the coalesced groupsAli Ghodsi2013-08-201-30/+35
| |
| * several of Reynold's suggestions implementedAli Ghodsi2013-08-201-15/+14
| |
| * space removedAli Ghodsi2013-08-201-1/+1
| |
| * use count rather than foreachAli Ghodsi2013-08-201-2/+1
| |
| * made preferredLocation a val of the surrounding case classAli Ghodsi2013-08-201-10/+3
| |
| * Fix bug in testsAli Ghodsi2013-08-202-6/+6
| |
| * Renamed split to partitionAli Ghodsi2013-08-201-11/+11
| |
| * word wrap before 100 chars per lineAli Ghodsi2013-08-202-41/+51
| |
| * added goals inline as commentAli Ghodsi2013-08-201-0/+21
| |
| * Large scale load and locality tests for the coalesced partitions addedAli Ghodsi2013-08-202-63/+118
| |
| * Bug, should compute slack wrt parent partition size, not number of binsAli Ghodsi2013-08-201-2/+2
| |
| * load balancing coalescerAli Ghodsi2013-08-202-11/+218
| |
* | Removed meaningless typesMark Hamstra2013-08-201-1/+1
|/
* Merge remote-tracking branch 'jey/hadoop-agnostic'Matei Zaharia2013-08-2029-2255/+178
|\ | | | | | | | | Conflicts: core/src/main/scala/spark/PairRDDFunctions.scala
| * Fix Maven build with Hadoop 0.23.9Jey Kottalam2013-08-181-0/+8
| |
| * Maven build now also works with YARNJey Kottalam2013-08-161-70/+0
| |
| * Don't mark hadoop-client as 'provided'Jey Kottalam2013-08-161-1/+0
| |
| * Maven build now works with CDH hadoop-2.0.0-mr1Jey Kottalam2013-08-161-52/+0
| |
| * Initial changes to make Maven build agnostic of hadoop versionJey Kottalam2013-08-161-58/+5
| |
| * Rename HadoopWriter to SparkHadoopWriter since it's outside of our packageJey Kottalam2013-08-152-6/+6
| |
| * Fix newTaskAttemptID to work under YARNJey Kottalam2013-08-151-1/+19
| |
| * re-enable YARN supportJey Kottalam2013-08-151-1/+13
| |
| * SparkEnv isn't available this early, and not needed anywayJey Kottalam2013-08-152-25/+0
| |
| * make SparkHadoopUtil a member of SparkEnvJey Kottalam2013-08-158-26/+31
| |
| * rename HadoopMapRedUtil => SparkHadoopMapRedUtil, HadoopMapReduceUtil => ↵Jey Kottalam2013-08-155-6/+7
| | | | | | | | SparkHadoopMapReduceUtil
| * add commentJey Kottalam2013-08-151-4/+4
| |
| * dynamically detect hadoop versionJey Kottalam2013-08-152-8/+48
| |
| * remove core/src/hadoop{1,2} dirsJey Kottalam2013-08-156-104/+0
| |
| * move yarn to its own directoryJey Kottalam2013-08-1510-1864/+0
| |
* | changeGeneration --> changeEpoch renamingMark Hamstra2013-08-201-2/+2
| |
* | Renamed 'priority' to 'jobId' and assorted minor changesMark Hamstra2013-08-205-59/+60
| |
* | Merge pull request #828 from mateiz/sched-improvementsMatei Zaharia2013-08-1941-965/+1034
|\ \ | | | | | | Scheduler fixes and improvements