关于 UDAF 里面 ListView 的疑问

Wed, 07 Sep 2022 01:24:05 -0700 

Hello all，

我看 ListView 使用的时候，有以下示例

 public class MyAccumulator {

    public ListView<String> list = new ListView<>();

    // or explicit:
    // {@literal @}DataTypeHint("ARRAY<STRING>")
    // public ListView<String> list = new ListView<>();

    public long count = 0L;
  }

public class MyAggregateFunction extends AggregateFunction<String,
MyAccumulator>

我想请教下大家，为什么需要在外层包裹一个 MyAccumulator 呢， 我实际测下来， 直接时用
AggregateFunction<String, ListView<String>> 在 getValue 的时候会报空指针异常

Flink 版本： 1.13.1

谢谢。


Zhiwen Sun

回复