SparkStream:4)foreachRDD詳解

foreachRDD一般用來把SparkStream運行獲得的結果保存到外部系統好比HDFS、Mysql、Redis等等。瞭解下面的知識能夠幫助咱們避免不少誤區java 誤區1:實例化外部鏈接對象的位置不正確,好比下面代碼mysql dstream.foreachRDD { rdd => val connection = createNewConnection() // executed a
相關文章
相關標籤/搜索