-
- Downloads
multi-tracker branch now compiles and runs; but it crashes right before the
end. The same problem is seen also in the master branch (in the ChainedStreaming implementation)
Showing
- Makefile 9 additions, 5 deletionsMakefile
- README 27 additions, 2 deletionsREADME
- conf/java-opts 1 addition, 0 deletionsconf/java-opts
- conf/log4j.properties 8 additions, 0 deletionsconf/log4j.properties
- conf/spark-env.sh 13 additions, 0 deletionsconf/spark-env.sh
- run 31 additions, 9 deletionsrun
- spark-executor 1 addition, 2 deletionsspark-executor
- src/examples/BroadcastTest.scala 7 additions, 11 deletionssrc/examples/BroadcastTest.scala
- src/examples/SparkALS.scala 0 additions, 5 deletionssrc/examples/SparkALS.scala
- src/examples/Vector.scala 1 addition, 1 deletionsrc/examples/Vector.scala
- src/scala/spark/Accumulators.scala 7 additions, 5 deletionssrc/scala/spark/Accumulators.scala
- src/scala/spark/Broadcast.scala 476 additions, 476 deletionssrc/scala/spark/Broadcast.scala
- src/scala/spark/ClosureCleaner.scala 4 additions, 4 deletionssrc/scala/spark/ClosureCleaner.scala
- src/scala/spark/Executor.scala 18 additions, 14 deletionssrc/scala/spark/Executor.scala
- src/scala/spark/HdfsFile.scala 22 additions, 11 deletionssrc/scala/spark/HdfsFile.scala
- src/scala/spark/LocalScheduler.scala 14 additions, 8 deletionssrc/scala/spark/LocalScheduler.scala
- src/scala/spark/Logging.scala 49 additions, 0 deletionssrc/scala/spark/Logging.scala
- src/scala/spark/MesosScheduler.scala 135 additions, 79 deletionssrc/scala/spark/MesosScheduler.scala
- src/scala/spark/ParallelArray.scala 8 additions, 7 deletionssrc/scala/spark/ParallelArray.scala
- src/scala/spark/RDD.scala 156 additions, 40 deletionssrc/scala/spark/RDD.scala
Loading
Please register or sign in to comment