SparkStream：4)foreachRDD详解

foreachRDD一般用来把SparkStream运行获得的结果保存到外部系统好比HDFS、Mysql、Redis等等。了解下面的知识能够帮助咱们避免不少误区java 误区1：实例化外部链接对象的位置不正确，好比下面代码mysql dstream.foreachRDD { rdd => val connection = createNewConnection() // executed a

>>阅读原文<<