Flink getResult（）的聚合功能可以更改累加器值？

Question

getResult（）函数可以更改累加器的值吗？在累积时仍会有效应值。 代码在下面：

public class WeightedAverage implements AggregateFunction<Datum, AverageAccumulator, Double> {

 public AverageAccumulator createAccumulator() {
     return new AverageAccumulator();
 }

 public AverageAccumulator merge(AverageAccumulator a, AverageAccumulator b) {
     a.count += b.count;
     a.sum += b.sum;
     return a;
 }

 public AverageAccumulator add(Datum value, AverageAccumulator acc) {
     acc.count += value.getWeight();
     acc.sum += value.getValue();
     return acc;
 }
 
 public Double getResult(AverageAccumulator acc) {
     int result = acc.sum / (double) acc.count;
     acc.count = 0; //here
     acc.sum = 0; //here
     return result;
 }

}

Answer 1

不，您不能在getResult期间修改累加器。

Flink将根据需要创建新的蓄能器（例如，对于每个新窗口）。