-
- Downloads
[SPARK-6028][Core]A new RPC implemetation based on the network module
Design doc: https://docs.google.com/document/d/1CF5G6rGVQMKSyV_QKo4D2M-x6rxz5x1Ew7aK3Uq6u8c/edit?usp=sharing Author: zsxwing <zsxwing@gmail.com> Closes #6457 from zsxwing/new-rpc.
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/SparkEnv.scala 15 additions, 5 deletionscore/src/main/scala/org/apache/spark/SparkEnv.scala
- core/src/main/scala/org/apache/spark/deploy/worker/Worker.scala 1 addition, 1 deletion...rc/main/scala/org/apache/spark/deploy/worker/Worker.scala
- core/src/main/scala/org/apache/spark/deploy/worker/WorkerWatcher.scala 5 additions, 8 deletions.../scala/org/apache/spark/deploy/worker/WorkerWatcher.scala
- core/src/main/scala/org/apache/spark/rpc/RpcCallContext.scala 1 addition, 1 deletion.../src/main/scala/org/apache/spark/rpc/RpcCallContext.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEndpoint.scala 26 additions, 25 deletionscore/src/main/scala/org/apache/spark/rpc/RpcEndpoint.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEndpointNotFoundException.scala 22 additions, 0 deletions...a/org/apache/spark/rpc/RpcEndpointNotFoundException.scala
- core/src/main/scala/org/apache/spark/rpc/RpcEnv.scala 5 additions, 2 deletionscore/src/main/scala/org/apache/spark/rpc/RpcEnv.scala
- core/src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala 3 additions, 3 deletions...src/main/scala/org/apache/spark/rpc/akka/AkkaRpcEnv.scala
- core/src/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala 218 additions, 0 deletions...rc/main/scala/org/apache/spark/rpc/netty/Dispatcher.scala
- core/src/main/scala/org/apache/spark/rpc/netty/IDVerifier.scala 39 additions, 0 deletions...rc/main/scala/org/apache/spark/rpc/netty/IDVerifier.scala
- core/src/main/scala/org/apache/spark/rpc/netty/Inbox.scala 220 additions, 0 deletionscore/src/main/scala/org/apache/spark/rpc/netty/Inbox.scala
- core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcAddress.scala 56 additions, 0 deletions...in/scala/org/apache/spark/rpc/netty/NettyRpcAddress.scala
- core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcCallContext.scala 87 additions, 0 deletions...cala/org/apache/spark/rpc/netty/NettyRpcCallContext.scala
- core/src/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala 504 additions, 0 deletions...c/main/scala/org/apache/spark/rpc/netty/NettyRpcEnv.scala
- core/src/main/scala/org/apache/spark/storage/BlockManagerSlaveEndpoint.scala 3 additions, 3 deletions.../org/apache/spark/storage/BlockManagerSlaveEndpoint.scala
- core/src/main/scala/org/apache/spark/util/ThreadUtils.scala 5 additions, 1 deletioncore/src/main/scala/org/apache/spark/util/ThreadUtils.scala
- core/src/test/scala/org/apache/spark/MapOutputTrackerSuite.scala 4 additions, 6 deletions...c/test/scala/org/apache/spark/MapOutputTrackerSuite.scala
- core/src/test/scala/org/apache/spark/SSLSampleConfigs.scala 2 additions, 0 deletionscore/src/test/scala/org/apache/spark/SSLSampleConfigs.scala
- core/src/test/scala/org/apache/spark/deploy/worker/WorkerWatcherSuite.scala 2 additions, 4 deletions...a/org/apache/spark/deploy/worker/WorkerWatcherSuite.scala
Loading
Please register or sign in to comment