|
Change Parameter Type checkpoints : ArrayDeque<Tuple2<Long,List<T>>> to checkpoints : ArrayDeque<Tuple2<Long,Set<T>>> in method public fromDeque(checkpoints ArrayDeque<Tuple2<Long,Set<T>>>, serializer TypeSerializer<T>, outputBuffer DataOutputSerializer) : SerializedCheckpointData[] in class org.apache.flink.runtime.state.SerializedCheckpointData |
From |
To |
|
Change Parameter Type uIds : List<UId> to uIds : Set<UId> in method protected abstract acknowledgeIDs(checkpointId long, uIds Set<UId>) : void in class org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase |
From |
To |
|
Change Parameter Type checkpoints : ArrayDeque<Tuple2<Long,List<T>>> to checkpoints : ArrayDeque<Tuple2<Long,Set<T>>> in method public fromDeque(checkpoints ArrayDeque<Tuple2<Long,Set<T>>>, serializer TypeSerializer<T>) : SerializedCheckpointData[] in class org.apache.flink.runtime.state.SerializedCheckpointData |
From |
To |
|
Change Parameter Type uniqueIds : List<UId> to uniqueIds : Set<UId> in method protected acknowledgeIDs(checkpointId long, uniqueIds Set<UId>) : void in class org.apache.flink.streaming.api.functions.source.MultipleIdsMessageAcknowledgingSourceBase |
From |
To |
|
Change Variable Type checkpointIds : List<T> to checkpointIds : Set<T> in method public fromDeque(checkpoints ArrayDeque<Tuple2<Long,Set<T>>>, serializer TypeSerializer<T>, outputBuffer DataOutputSerializer) : SerializedCheckpointData[] in class org.apache.flink.runtime.state.SerializedCheckpointData |
From |
To |
|
Change Variable Type deque : ArrayDeque<Tuple2<Long,List<String>>> to deque : ArrayDeque<Tuple2<Long,Set<String>>> in method public testCheckpointing() : void in class org.apache.flink.streaming.connectors.rabbitmq.RMQSourceTest |
From |
To |
|
Change Variable Type checkpoint : Tuple2<Long,List<T>> to checkpoint : Tuple2<Long,Set<T>> in method public fromDeque(checkpoints ArrayDeque<Tuple2<Long,Set<T>>>, serializer TypeSerializer<T>, outputBuffer DataOutputSerializer) : SerializedCheckpointData[] in class org.apache.flink.runtime.state.SerializedCheckpointData |
From |
To |
|
Change Variable Type iter : Iterator<Tuple2<Long,List<UId>>> to iter : Iterator<Tuple2<Long,Set<UId>>> in method public notifyCheckpointComplete(checkpointId long) : void in class org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase |
From |
To |
|
Change Variable Type messageIds : List<String> to messageIds : Set<String> in method public testCheckpointing() : void in class org.apache.flink.streaming.connectors.rabbitmq.RMQSourceTest |
From |
To |
|
Change Variable Type deque : ArrayDeque<Tuple2<Long,List<T>>> to deque : ArrayDeque<Tuple2<Long,Set<T>>> in method public toDeque(data SerializedCheckpointData[], serializer TypeSerializer<T>) : ArrayDeque<Tuple2<Long,Set<T>>> in class org.apache.flink.runtime.state.SerializedCheckpointData |
From |
To |
|
Change Variable Type ids : List<T> to ids : Set<T> in method public toDeque(data SerializedCheckpointData[], serializer TypeSerializer<T>) : ArrayDeque<Tuple2<Long,Set<T>>> in class org.apache.flink.runtime.state.SerializedCheckpointData |
From |
To |
|
Change Variable Type checkpoint : Tuple2<Long,List<UId>> to checkpoint : Tuple2<Long,Set<UId>> in method public notifyCheckpointComplete(checkpointId long) : void in class org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase |
From |
To |
|
Change Variable Type checkpoint : Tuple2<Long,List<UId>> to checkpoint : Tuple2<Long,Set<UId>> in method public initializeState(context FunctionInitializationContext) : void in class org.apache.flink.streaming.api.functions.source.MessageAcknowledgingSourceBase |
From |
To |