在使用SparkStreaming时,使用StreamingContext.getOrCreate(checkpointDirectory, functionToCreateContext _)创建StreamingContext。代码示例如下:

// Function to create and setup a new StreamingContext    def functionToCreateContext(): StreamingContext = {      val conf = new SparkConf().setAppName("UserBrowse")      val ssc = new StreamingContext(conf, batchInterval)      //通过LogHubCu
收藏 打印