-
- Downloads
[SPARK-7223] Rename RPC askWithReply -> askWithReply, sendWithReply -> ask.
The old naming scheme was very confusing between askWithReply and sendWithReply. I also divided RpcEnv.scala into multiple files. Author: Reynold Xin <rxin@databricks.com> Closes #5768 from rxin/rpc-rename and squashes the following commits: a84058e [Reynold Xin] [SPARK-7223] Rename RPC askWithReply -> askWithReply, sendWithReply -> ask.
Showing
- core/src/main/scala/org/apache/spark/MapOutputTracker.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/MapOutputTracker.scala
- core/src/main/scala/org/apache/spark/SparkContext.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/SparkContext.scala
- core/src/main/scala/org/apache/spark/executor/CoarseGrainedExecutorBackend.scala 2 additions, 2 deletions.../apache/spark/executor/CoarseGrainedExecutorBackend.scala
- core/src/main/scala/org/apache/spark/executor/Executor.scala 1 addition, 1 deletioncore/src/main/scala/org/apache/spark/executor/Executor.scala
- core/src/main/scala/org/apache/spark/rpc/RpcCallContext.scala 41 additions, 0 deletions.../src/main/scala/org/apache/spark/rpc/RpcCallContext.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEndpoint.scala 148 additions, 0 deletionscore/src/main/scala/org/apache/spark/rpc/RpcEndpoint.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEndpointRef.scala 119 additions, 0 deletions.../src/main/scala/org/apache/spark/rpc/RpcEndpointRef.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala 34 additions, 279 deletionscore/src/main/scala/org/apache/spark/rpc/RpcEnv.scala
- core/src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala 1 addition, 1 deletion...src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala
- core/src/main/scala/org/apache/spark/scheduler/DAGScheduler.scala 1 addition, 1 deletion.../main/scala/org/apache/spark/scheduler/DAGScheduler.scala
- core/src/main/scala/org/apache/spark/scheduler/OutputCommitCoordinator.scala 1 addition, 1 deletion.../org/apache/spark/scheduler/OutputCommitCoordinator.scala
- core/src/main/scala/org/apache/spark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala 3 additions, 3 deletions...ark/scheduler/cluster/CoarseGrainedSchedulerBackend.scala
- core/src/main/scala/org/apache/spark/scheduler/cluster/YarnSchedulerBackend.scala 4 additions, 4 deletions...apache/spark/scheduler/cluster/YarnSchedulerBackend.scala
- core/src/main/scala/org/apache/spark/scheduler/local/LocalBackend.scala 1 addition, 1 deletion...scala/org/apache/spark/scheduler/local/LocalBackend.scala
- core/src/main/scala/org/apache/spark/storage/BlockManagerMaster.scala 14 additions, 14 deletions...n/scala/org/apache/spark/storage/BlockManagerMaster.scala
- core/src/main/scala/org/apache/spark/storage/BlockManagerMasterEndpoint.scala 6 additions, 6 deletions...org/apache/spark/storage/BlockManagerMasterEndpoint.scala
- core/src/test/scala/org/apache/spark/HeartbeatReceiverSuite.scala 2 additions, 2 deletions.../test/scala/org/apache/spark/HeartbeatReceiverSuite.scala
- core/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala 10 additions, 10 deletionscore/src/test/scala/org/apache/spark/rpc/RpcEnvSuite.scala
- core/src/test/scala/org/apache/spark/storage/BlockManagerSuite.scala 1 addition, 1 deletion...st/scala/org/apache/spark/storage/BlockManagerSuite.scala
- streaming/src/main/scala/org/apache/spark/streaming/receiver/ReceiverSupervisorImpl.scala 3 additions, 3 deletions...che/spark/streaming/receiver/ReceiverSupervisorImpl.scala
Loading
Please register or sign in to comment