Spark RPC是通过Akka类库实现的,Akka 是用Scala开发的,基于Actor并发模型实现
重要的类
ActorSystem, 通常是一个单例对象, 可以用这个对象创建很多Actor
Actor, 负责通信,主要有 preStart(), receive()
Spark 中Akka的消息模型
2024-04-11 18:41:07
Spark RPC是通过Akka类库实现的,Akka 是用Scala开发的,基于Actor并发模型实现
重要的类
ActorSystem, 通常是一个单例对象, 可以用这个对象创建很多Actor
Actor, 负责通信,主要有 preStart(), receive()
Spark 中Akka的消息模型