【Spark篇】---SparkStreaming算子操作transform和updateStateByKey

一、前述 今天分享一篇SparkStreaming常用的算子transform和updateStateByKey。 可以通過transform算子，對Dstream做RDD到RDD的任意操作。其實就是DStream的類型轉換。             算子內，拿到的RDD算子外，代碼是在Driver端執行的，每個batchInterval執行一次，可以做到動態改變廣播變量。 爲SparkStrea

>>阅读原文<<