When I use Flink's ListView as an intermediate res...
# troubleshooting
a
When I use Flink's ListView as an intermediate result for UDAF, the performance is very good, but when I use an ArrayList, the performance becomes very poor. The explanation of the ListView states that it will enable the state backend when encountering large amounts of data. In which class does this process occur, and how should I debug this conversion process?
Copy code
public static class State implements Serializable {

    public int scale = 2;

    @DataTypeHint(value = "ARRAY<DOUBLE>")
    public ArrayList<Double> numbers;

    public State() {}
}

@Override
public State createAccumulator() {
    State state = new State();
    state.numbers = new ArrayList<>();
    return state;
}
public static class State implements Serializable {

    public int scale = 2;

    public ListView<Double> numbers;

    public State() {}
}
Copy code
@Override
public State createAccumulator() {
    State state = new State();
    state.numbers = new ListView<>();
    return state;
}
message has been deleted