Github user fhueske commented on a diff in the pull request:
https://github.com/apache/flink/pull/4736#discussion_r142256742
--- Diff:
flink-libraries/flink-table/src/test/java/org/apache/flink/table/runtime/utils/JavaUserDefinedAggFunctions.java
---
@@ -86,6 +86,13 @@ public Long getValue(WeightedAvgAccum accumulator) {
}
// overloaded accumulate method
+ // dummy to test constants
+ public void accumulate(WeightedAvgAccum accumulator, long
iValue, int iWeight, int x, String string) {
+ accumulator.sum += iWeight + Integer.parseInt(string);
--- End diff --
change the method to
```
accumulator.sum += (iValue + Integer.parseInt(string)) * iWeight;
accumulator.count += iWeight;
```
to have some influence of the value of `string` in the result?
---