sparkStreaming轉換算子

map 代碼--》集羣 nc--》端口 9000 (可以修改) 替換  字 flatmap 切分壓平 filter  repartition union合併  【local【2】】 當只有兩個的時候  只有一個分區  另一個處理數據集 count reduce ************************   join 和 cogroup 用兩個隊列join transform  ******
相關文章
相關標籤/搜索