Sparkstreaming是如何获取数据组成Dstream的源码浅析

前面一篇文章介绍了SparkStreaming是如何不停的循环submitJob的, 链接: http://humingminghz.iteye.com/admin/blogs/2308711 既然已经知道了Spark Streaming如何循环处理, 那么咱们就要看一下处理过程当中是怎么获取到Dstream的, 用简单的socketTextStream 来作一个列子, 入口: val lines
相关文章
相关标签/搜索