本文共 475 字，大约阅读时间需要 1 分钟。

1.参考官网

2.构建方法

（1）使用SparkConf构建

import org.apache.spark._import org.apache.spark.streaming._val conf = new SparkConf().setAppName(appName).setMaster(master)val ssc = new StreamingContext(conf, Seconds(1))

（2）使用SparkContext构建

import org.apache.spark.streaming._val conf = new SparkConf().setAppName(appName).setMaster(master)  val sc = SparkContext.getOrCreate(conf)   // existing SparkContext// 或者：val sc = new SparkContext(conf) val ssc = new StreamingContext(sc, Seconds(1))

转载地址：http://qvygi.baihongyu.com/