-
- Downloads
Some refactoring to make cluster scheduler pluggable.
Showing
- core/src/main/scala/spark/PairRDDFunctions.scala 9 additions, 2 deletionscore/src/main/scala/spark/PairRDDFunctions.scala
- core/src/main/scala/spark/SparkContext.scala 7 additions, 6 deletionscore/src/main/scala/spark/SparkContext.scala
- core/src/main/scala/spark/TaskContext.scala 1 addition, 1 deletioncore/src/main/scala/spark/TaskContext.scala
- core/src/main/scala/spark/TaskState.scala 32 additions, 0 deletionscore/src/main/scala/spark/TaskState.scala
- core/src/main/scala/spark/Utils.scala 10 additions, 0 deletionscore/src/main/scala/spark/Utils.scala
- core/src/main/scala/spark/deploy/DeployMessage.scala 4 additions, 3 deletionscore/src/main/scala/spark/deploy/DeployMessage.scala
- core/src/main/scala/spark/deploy/ExecutorState.scala 3 additions, 1 deletioncore/src/main/scala/spark/deploy/ExecutorState.scala
- core/src/main/scala/spark/deploy/JobDescription.scala 0 additions, 1 deletioncore/src/main/scala/spark/deploy/JobDescription.scala
- core/src/main/scala/spark/deploy/client/TestClient.scala 2 additions, 2 deletionscore/src/main/scala/spark/deploy/client/TestClient.scala
- core/src/main/scala/spark/deploy/client/TestExecutor.scala 3 additions, 0 deletionscore/src/main/scala/spark/deploy/client/TestExecutor.scala
- core/src/main/scala/spark/deploy/master/JobState.scala 2 additions, 0 deletionscore/src/main/scala/spark/deploy/master/JobState.scala
- core/src/main/scala/spark/deploy/worker/ExecutorManager.scala 6 additions, 3 deletions.../src/main/scala/spark/deploy/worker/ExecutorManager.scala
- core/src/main/scala/spark/deploy/worker/Worker.scala 5 additions, 4 deletionscore/src/main/scala/spark/deploy/worker/Worker.scala
- core/src/main/scala/spark/deploy/worker/WorkerArguments.scala 3 additions, 1 deletion.../src/main/scala/spark/deploy/worker/WorkerArguments.scala
- core/src/main/scala/spark/executor/Executor.scala 37 additions, 88 deletionscore/src/main/scala/spark/executor/Executor.scala
- core/src/main/scala/spark/executor/ExecutorContext.scala 11 additions, 0 deletionscore/src/main/scala/spark/executor/ExecutorContext.scala
- core/src/main/scala/spark/executor/MesosExecutorRunner.scala 68 additions, 0 deletionscore/src/main/scala/spark/executor/MesosExecutorRunner.scala
- core/src/main/scala/spark/scheduler/ResultTask.scala 1 addition, 1 deletioncore/src/main/scala/spark/scheduler/ResultTask.scala
- core/src/main/scala/spark/scheduler/ShuffleMapTask.scala 1 addition, 1 deletioncore/src/main/scala/spark/scheduler/ShuffleMapTask.scala
- core/src/main/scala/spark/scheduler/Task.scala 1 addition, 1 deletioncore/src/main/scala/spark/scheduler/Task.scala
Loading
Please register or sign in to comment