-
- Downloads
Merge in engine improvements from the Spark Streaming project, developed
jointly with Tathagata Das and Haoyuan Li. This commit imports the changes and ports them to Mesos 0.9, but does not yet pass unit tests due to various classes not supporting a graceful stop() yet.
Showing
- bagel/src/main/scala/spark/bagel/examples/WikipediaPageRankStandalone.scala 6 additions, 5 deletions...la/spark/bagel/examples/WikipediaPageRankStandalone.scala
- core/src/main/scala/spark/BlockStoreShuffleFetcher.scala 70 additions, 0 deletionscore/src/main/scala/spark/BlockStoreShuffleFetcher.scala
- core/src/main/scala/spark/BoundedMemoryCache.scala 2 additions, 1 deletioncore/src/main/scala/spark/BoundedMemoryCache.scala
- core/src/main/scala/spark/CacheTracker.scala 176 additions, 158 deletionscore/src/main/scala/spark/CacheTracker.scala
- core/src/main/scala/spark/CoGroupedRDD.scala 4 additions, 2 deletionscore/src/main/scala/spark/CoGroupedRDD.scala
- core/src/main/scala/spark/DAGScheduler.scala 0 additions, 374 deletionscore/src/main/scala/spark/DAGScheduler.scala
- core/src/main/scala/spark/Dependency.scala 1 addition, 1 deletioncore/src/main/scala/spark/Dependency.scala
- core/src/main/scala/spark/DiskSpillingCache.scala 0 additions, 75 deletionscore/src/main/scala/spark/DiskSpillingCache.scala
- core/src/main/scala/spark/DoubleRDDFunctions.scala 39 additions, 0 deletionscore/src/main/scala/spark/DoubleRDDFunctions.scala
- core/src/main/scala/spark/Executor.scala 16 additions, 10 deletionscore/src/main/scala/spark/Executor.scala
- core/src/main/scala/spark/FetchFailedException.scala 5 additions, 3 deletionscore/src/main/scala/spark/FetchFailedException.scala
- core/src/main/scala/spark/JavaSerializer.scala 21 additions, 18 deletionscore/src/main/scala/spark/JavaSerializer.scala
- core/src/main/scala/spark/Job.scala 0 additions, 16 deletionscore/src/main/scala/spark/Job.scala
- core/src/main/scala/spark/KryoSerializer.scala 68 additions, 30 deletionscore/src/main/scala/spark/KryoSerializer.scala
- core/src/main/scala/spark/Logging.scala 6 additions, 1 deletioncore/src/main/scala/spark/Logging.scala
- core/src/main/scala/spark/MapOutputTracker.scala 53 additions, 55 deletionscore/src/main/scala/spark/MapOutputTracker.scala
- core/src/main/scala/spark/PairRDDFunctions.scala 39 additions, 17 deletionscore/src/main/scala/spark/PairRDDFunctions.scala
- core/src/main/scala/spark/ParallelShuffleFetcher.scala 0 additions, 119 deletionscore/src/main/scala/spark/ParallelShuffleFetcher.scala
- core/src/main/scala/spark/Partitioner.scala 0 additions, 1 deletioncore/src/main/scala/spark/Partitioner.scala
- core/src/main/scala/spark/PipedRDD.scala 1 addition, 0 deletionscore/src/main/scala/spark/PipedRDD.scala
Loading
Please register or sign in to comment