map算子
1.在集群中启动nc 只启动服务器
2.如下图
mapflap
1.在集群中启动nc 只启动服务器
2.如下图
filter
1.在集群中启动nc 只启动服务器
foreach
Union算子
Count算子
reduce算子
countByValue算子
Join算子
Transformation算子
***************************************************
updataStateByKey算子
有状态的算子全局累加
窗口滑动
发电机房
保存算子
