初始化StreamingContext 初始化一个SparkStreaming程序，必须创建StreamingContext对象，因为它是SparkStreaming处理流式数据的入口。 def main(args: Array[String]): Unit = {//初始化SparkConfval conf = new SparkConf().setMaster("local[2]").s