deque.addLast(new Tuple2<Long,List<T>>(checkpoint.checkpointId,ids)); | deque.addLast(new Tuple2<Long,Set<T>>(checkpoint.checkpointId,ids)); | new Tuple2<Long,List<T>>(checkpoint.checkpointId,ids) | new Tuple2<Long,Set<T>>(checkpoint.checkpointId,ids) | flink | 76f1022884fe7b291fe81028a29896fb5b5ca5c9 | org.apache.flink.runtime.state.SerializedCheckpointData | | | TCIVar | ids |
---|
v0 | checkpoint.checkpointId |
---|
| - org.apache.flink.api.java.tuple.Tuple2
| TCIVar | ids |
---|
v0 | checkpoint.checkpointId |
---|
| Uses | True |