[GitHub] flink pull request #4963: [FLINK-7475] [core][DataStream API] support update...

[bowenli86]

Github user bowenli86 commented on a diff in the pull request:

    https://github.com/apache/flink/pull/4963#discussion_r159545896
  
    --- Diff: 
flink-runtime/src/main/java/org/apache/flink/runtime/state/heap/HeapListState.java
 ---
    @@ -120,4 +121,16 @@ public void add(V value) {
                a.addAll(b);
                return a;
        }
    +
    +   @Override
    +   public void update(List<V> values) throws Exception {
    +           clear();
    +
    +           if (values != null && !values.isEmpty()) {
    +                   final N namespace = currentNamespace;
    +                   final StateTable<K, N, ArrayList<V>> map = stateTable;
    +
    +                   map.put(namespace, new ArrayList<>(values));
    --- End diff --
    
    because `values` is of `List` and `map` only is of `ArrayList`, need to 
enforce strict subclass


---