本文基于 spark 1.6.2本次的源码全来自 org.apache.spark.streaming.receiver 这个 package 下,包括 BlockGenerator.scala, RateLimiter, ReceiverdBlock.scala, ReceivedBlockHandler.scala, Receiver.scala, ReceiverSupervisor.scala, ReceiverSupervisorImpl.scala
org.apache.spark.streaming.receiver
BlockGenerator.scala
RateLimiter
ReceiverdBlock.scala
ReceivedBlockHandler.scala
Receiver.scala
ReceiverSupervisor.scala
ReceiverSupervisorImpl.scala