Question

如何定时清空sparkstreaming的统计结果，重新开始统计

Answer 1

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