-
- Downloads
Remove deprecated actorFor and use actorSelection everywhere.
Showing
- core/src/main/scala/org/apache/spark/MapOutputTracker.scala 6 additions, 2 deletionscore/src/main/scala/org/apache/spark/MapOutputTracker.scala
- core/src/main/scala/org/apache/spark/SparkEnv.scala 4 additions, 4 deletionscore/src/main/scala/org/apache/spark/SparkEnv.scala
- core/src/main/scala/org/apache/spark/deploy/client/Client.scala 5 additions, 18 deletions...rc/main/scala/org/apache/spark/deploy/client/Client.scala
- core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala 17 additions, 6 deletions...rc/main/scala/org/apache/spark/deploy/worker/Worker.scala
- core/src/main/scala/org/apache/spark/storage/BlockManagerMaster.scala 15 additions, 10 deletions...n/scala/org/apache/spark/storage/BlockManagerMaster.scala
- core/src/main/scala/org/apache/spark/storage/ThreadingTest.scala 1 addition, 1 deletion...c/main/scala/org/apache/spark/storage/ThreadingTest.scala
- core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala 7 additions, 7 deletions...c/test/scala/org/apache/spark/MapOutputTrackerSuite.scala
- core/src/test/scala/org/apache/spark/storage/BlockManagerSuite.scala 1 addition, 1 deletion...st/scala/org/apache/spark/storage/BlockManagerSuite.scala
- examples/src/main/scala/org/apache/spark/streaming/examples/ActorWordCount.scala 1 addition, 1 deletion.../org/apache/spark/streaming/examples/ActorWordCount.scala
- streaming/src/main/scala/org/apache/spark/streaming/dstream/NetworkInputDStream.scala 1 addition, 1 deletion.../apache/spark/streaming/dstream/NetworkInputDStream.scala
Loading
Please register or sign in to comment