初始化的过程主要可以概括为两点: 1)调度器的初始化。 调度器调度 Spark Streaming 的运行,用户可以通过配置相关参数进行调优。 2)将输入流的接收器转化为 RDD 在集群进行分布式分配,然后启动接收器集合中的每个接收器。