apache-flink - Flink - 如何同时计算总和和平均值？

Question

Flink(batch/streaming)有没有办法同时计算一个字段的平均值和总和？使用聚合方法，我可以计算 groupBy 结果中某个字段的总和，但是如何同时计算平均值呢？下面的示例代码。

ExecutionEnvironment env = ExecutionEnvironment.getExecutionEnvironment();
DataSet<Tuple3<String,Integer,Double>> source = 
         env.readCsvFile(PathConfig.LINEITEM_1)
         .fieldDelimiter("|")
         types(String.class, Integer.class, Double.class);

source.groupBy(0,1).aggregate(Aggregations.SUM, 2);
//average of field 2???

Answer 1

对于 CSV 解析、分组和聚合等简单任务，我建议使用 Flink 的 Table API .

如果您想使用更多低级 API，您可以实现 GroupReduce求和/计数(直到迭代器没有更多元素)并在最后产生最终平均值的函数。