SparkR principle | R spark 集成原理

RRunner.scala启动RBackend.scala来接收R的消息

RRunner.scala也启动了backend.R

backend.R让R的代码可以调用scala的东西

然后就是context.R生成RDD.R

RDD.R调用scala的东西

RDD.R里的getJRDD()方法就是导致RRDD.scala的一些事

————-master|worker分界线—————

就是RRDD.scala里的compute（）方法的事了

不多说也是socket和ProcessBuilder