Spark Streaming应用启动过程分析

  本文为SparkStreaming源码剖析的第三篇,主要分析SparkStreaming启动过程。   在调用StreamingContext.start方法后,进入JobScheduler.start方法中,各子元素start方法的调用顺序以下:php private var eventLoop : EventLoop[JobSchedulerEvent] = null val listen
相关文章
相关标签/搜索