第3课:通过案例对SparkStreaming 透彻理解三板斧之三:解密SparkStreaming运行机制和架构进阶.
//设置batchDuration时间间隔
val ssc =new StreamingContext (conf,Seconds
(5))
真正的调度 ssc.start
在StreamingContext调用start方法的内部其实是一次启动JobScheduler的
第3课:通过案例对SparkStreaming 透彻理解三板斧之三:解密SparkStreaming运行机制和架构进阶.
//设置batchDuration时间间隔
val ssc =new StreamingContext (conf,Seconds
(5))
真正的调度 ssc.start
在StreamingContext调用start方法的内部其实是一次启动JobScheduler的
微信扫码登录