sum算子的功能对该字段进行加和,并将结果保存在该字段上。min操作无法确定其他字段的数值。...= tupleStream.keyBy(0).sum(1).print()
max算子对该字段求最大值,并将结果保存在该字段上。...// 按第一个字段分组,对第三个字段求最大值max,打印出来的结果如下:
// (0,0,0)
// (0,0,1)
// (0,0,2)
// (1,0,6)
// (1,0,7)
//...// 按第一个字段分组,对第三个字段求最大值maxBy,打印出来的结果如下:
// (0,0,0)
// (0,1,1)
// (0,2,2)
// (1,0,6)
// (1,1,7)
//...其实,这些aggregation操作里已经封装了状态数据,比如,sum算子内部记录了当前的和,max算子内部记录了当前的最大值。