摘要： 1.1 创建StreamingContext对象 1.1.1通过SparkContext创建 源码如下： 第一参数为sparkContext对象，第二个参数为批次时间； 创建实例： val ssc = new StreamingContext(sc, Seconds(5)) 1.1.2通过Spark 阅读全文