### ispark-rpc
基于Spark Core 2.4.4，在分析完Spark Core的主要源码后，从其中剥离出一个可用的rpc基础框架以实现机器间的快速高效通信，从而提升
目前正在开发的推送系统的Push效率。
基于Spark 2.4.4实现的RPC框架，基于该框架的实现将PUSH速度提升了约一倍+源代码+文档说明
版权申诉
102 浏览量
2024-04-15
17:46:59
上传
评论
收藏 502KB ZIP 举报
基于Spark 2.4.4实现的RPC框架，基于该框架的实现将PUSH速度提升了约一倍+源代码+文档说明
（299个子文件） 
BaseRpcTest.class 50KB NettyRpcEnv.class 25KB NextIterator.class 24KB Dispatcher.class 16KB ISparkRpcConf.class 15KB ThreadUtils$.class 14KB Utils$.class 10KB RpcOutboxMessage.class 10KB ComplexMessage.class 9KB RpcEnvCustomConfig.class 9KB Inbox.class 8KB Outbox.class 8KB NettyRpcHandler.class 8KB NettyRpcEndpointRef.class 7KB RpcEnvServerConfig.class 7KB OneWayOutboxMessage.class 7KB RpcMessage.class 6KB RequestMessage.class 6KB RpcEndpointAddress.class 6KB RpcEnvClientConfig.class 6KB Inbox$$anonfun$process$1.class 6KB ThreadUtils.class 6KB RemoteProcessConnectionError.class 6KB RpcEndpointVerifier.class 5KB OneWayMessage.class 5KB RpcAddress.class 5KB RemoteProcessDisconnected.class 5KB RemoteProcessConnected.class 5KB SayTimeout.class 5KB RpcEnv.class 5KB JavaSerializerInstance.class 5KB RpcTimeout.class 5KB JavaSerializer.class 5KB RpcFailure.class 5KB SimpleRpcTest$$anonfun$7.class 5KB SayUnexpectedFailure.class 4KB Utils$$anonfun$startServiceOnPort$1.class 4KB SayHello.class 4KB EchoEndpoint.class 4KB Say.class 4KB SimpleRpcTest$$anonfun$12.class 4KB HelloEndpoint.class 4KB SimpleRpcTest$$anonfun$8.class 4KB Utils.class 4KB SimpleRpcTest$$anonfun$3.class 4KB SimpleRpcTest$$anonfun$6.class 4KB RpcEndpointRef.class 4KB FstSerializationStream.class 4KB SimpleRpcTest$$anonfun$9.class 4KB RpcUtils$.class 4KB EchoEndpoint$$anonfun$receiveAndReply$1.class 4KB SimpleRpcTest$$anonfun$10.class 4KB SimpleRpcTest.class 4KB SimpleRpcTest$$anonfun$5.class 4KB RpcTimeout$.class 4KB SimpleRpcTest$$anonfun$2$$anonfun$assertBlock$1$1.class 4KB SimpleRpcTest$$anonfun$4.class 4KB SimpleRpcTest$$anonfun$2.class 4KB SimpleRpcTest$$anonfun$13.class 4KB SimpleRpcTest$$anonfun$11.class 4KB RpcEnvCustomConfig$.class 4KB SimpleRpcTest$$anonfun$1.class 3KB SimpleRpcTest$$anonfun$11$$anonfun$assertBlock$2$1.class 3KB RpcEndpointAddress$.class 3KB SimpleRpcTest$$anonfun$assertBlock$1.class 3KB SimpleClientTest$.class 3KB RpcServerTest$.class 3KB RpcEndpoint$class.class 3KB ComplexMessage$.class 3KB BaseRpcTest$$anonfun$runServerAndAwaitTermination$1.class 3KB NettyRpcEnvFactory$.class 3KB RpcOutboxMessage$.class 3KB Dispatcher$MessageLoop.class 3KB FstDeserializationStream.class 3KB JavaDeserializationStream.class 3KB SimpleRpcTest$$anonfun$12$$anonfun$apply$mcV$sp$13.class 3KB Outbox$$anon$1.class 3KB RequestMessage$.class 3KB RpcMessage$.class 3KB RpcEnvServerConfig$.class 3KB JavaSerializationStream.class 3KB ByteBufferOutputStream.class 3KB SimpleRpcTest$$anonfun$9$$anonfun$28.class 3KB RpcEndpointVerifier$CheckExistence.class 3KB HelloEndpoint$$anonfun$receiveAndReply$1.class 3KB SimpleRpcTest$$anonfun$3$$anonfun$16.class 3KB SimpleRpcTest$$anonfun$5$$anonfun$20.class 3KB SimpleRpcTest$$anonfun$4$$anonfun$18.class 3KB ISparkRpcTransportConf$.class 3KB SimpleRpcTest$$anonfun$8$$anonfun$26.class 3KB Dispatcher$$anonfun$postToAll$1.class 3KB RpcEndpointVerifier$$anonfun$receiveAndReply$1.class 3KB SimpleRpcTest$$anonfun$6$$anonfun$22.class 3KB SerializationStream.class 3KB BaseRpcTest$$anonfun$2.class 3KB SimpleRpcTest$$anonfun$7$$anonfun$24.class 3KB RemoteProcessConnectionError$.class 2KB ByteBufferInputStream.class 2KB SerializerInstance.class 2KB EchoEndpoint$$anonfun$receive$1.class 2KB共 299 条
- 1
- 2
- 3
资源评论
机器学习的喵
- 粉丝: 507
- 资源: 1269
下载权益
C知道特权
VIP文章
课程特权
VIP享7折，此内容立减5.97元 开通VIP
