Skip to content

Commit

Permalink
Update readme.md
Browse files Browse the repository at this point in the history
  • Loading branch information
lei-zuquan authored Sep 14, 2020
1 parent 2167fcf commit 1ab966c
Showing 1 changed file with 5 additions and 5 deletions.
10 changes: 5 additions & 5 deletions readme.md
Original file line number Diff line number Diff line change
Expand Up @@ -16,11 +16,11 @@ socket通信、本地创建数据、从磁盘文件、从Kafka消息中间件中
- reduce: 对key-value数据进行“滚动”压缩。将当前元素与最后一个减少的值合并,并发出新值
- fold: 带有初始值的key-value数据流上的“滚动”折叠。将当前元素与上一个折叠值组合在一起并发出新值
- Aggregations: 在key-value 数据流上滚动聚合。min和minBy之间的区别是min返回最小值,而minBy返回在此字段中具有最小值的元素(与max和maxBy相同)
+ sum
+ min
+ max
+ minBy
+ maxBy
* sum
* min
* max
* minBy
* maxBy
- window
- union
- connect
Expand Down

0 comments on commit 1ab966c

Please sign in to comment.