第25课:spark streaming的streamingContext启动及Jobschedule启动源码图解
1 streamingContext启动 2 Jobschedule启动源码图解
/* * *王家林老师授课http://weibo.com/ilovepains */ 每天晚上20:00YY频道现场授课频道68917580
StreamingContext.start:
1,validate
2,newThread(JobScheduler)
3,state:ACTIVE
4,metricsSystem
5,uiTab
JobScheduler.start 会引发三个消息循环体的运行,其中有两个是本地的消息循环体,另外一个是RPC消息循环体
eventLoop: