DStream之轉換操做(Transformation)

與 RDDs 相似,轉換容許修改輸入 DStream 中的數據。DStreams 支持許多在普通 Spark RDD 上可用的轉換算子。一些常見的轉換操做定義以下:java map(func) 經過函數 func 傳遞源 DStream 的每一個元素來返回一個新的DStream。web flatMap(func) 與 map 相似,可是每一個輸入項能夠映射到 0 或多個輸出項。數據庫 filter
相關文章
相關標籤/搜索