正在每个光阳区间初步的时候，一个新的批次就创立出来，正在该区间内支到的数据都会被添加到那个批次中，正在光阳区间完毕时，批次进止删加。每个输入批次都造成一个RDD，以Spark做业的方式办理并生成其余的RDD，办理的结果可以以批办理的方式传给外部系统。一个动态的工做控制器，将间断的streaming data切分数据片段，并依照模板复制出新的RDD DAG的真例，对数据片段停行办理；ReceiZZZer停行本始数据的孕育发作和导入；以及对永劫运止任务的保障，蕴含输入数据的失效后的重构，办理任务的失败后的重调。
