sparkStreaming转换算子02

map算子

1.在集群中启动nc  只启动服务器 

       

2.如下图

mapflap

1.在集群中启动nc  只启动服务器 

2.如下图

　　

filter

1.在集群中启动nc  只启动服务器 

foreach

Union算子

 Count算子

 reduce算子

 countByValue算子

 Join算子

 Transformation算子

*************************************************** 

updataStateByKey算子

有状态的算子全局累加

 窗口滑动

发电机房 

保存算子