|
Rename Method private createPartitionedStateJobGraph(parallelism int, maxParallelism int, numberKeys int, numberElements int, terminateAfterEmission boolean, checkpointingInterval int) : JobGraph renamed to private createJobGraphWithKeyedState(parallelism int, maxParallelism int, numberKeys int, numberElements int, terminateAfterEmission boolean, checkpointingInterval int) : JobGraph in class org.apache.flink.test.checkpointing.RescalingITCase |
From |
To |
|
Rename Method public testSavepointRescalingWithPartitionedState() : void renamed to public testSavepointRescalingWithKeyedAndNonPartitionedState() : void in class org.apache.flink.test.checkpointing.RescalingITCase |
From |
To |
|
Rename Method public testSavepointRescalingWithPartiallyNonPartitionedState() : void renamed to public testSavepointRescalingKeyedState(scaleOut boolean) : void in class org.apache.flink.test.checkpointing.RescalingITCase |
From |
To |
|
Rename Method private createPartitionedNonPartitionedStateJobGraph(parallelism int, maxParallelism int, fixedParallelism int, numberKeys int, numberElements int, terminateAfterEmission boolean, checkpointingInterval int) : JobGraph renamed to private createJobGraphWithKeyedAndNonPartitionedOperatorState(parallelism int, maxParallelism int, fixedParallelism int, numberKeys int, numberElements int, terminateAfterEmission boolean, checkpointingInterval int) : JobGraph in class org.apache.flink.test.checkpointing.RescalingITCase |
From |
To |
|
Rename Method public testSavepointRescalingFailureWithNonPartitionedState() : void renamed to public testSavepointRescalingNonPartitionedStateCausesException() : void in class org.apache.flink.test.checkpointing.RescalingITCase |
From |
To |
|
Rename Method private createNonPartitionedStateJobGraph(parallelism int, maxParallelism int, checkpointInterval long) : JobGraph renamed to private createJobGraphWithOperatorState(parallelism int, maxParallelism int, partitionedOperatorState boolean) : JobGraph in class org.apache.flink.test.checkpointing.RescalingITCase |
From |
To |
|
Change Variable Type namespaceSerializer : TypeSerializer to namespaceSerializer : TypeSerializer<N> in method private writeStateTableForKeyGroup(outView DataOutputView, stateTable StateTable<K,N,S>, keyGroupIndex int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type namespaceMap : Map<?,? extends Map<K,?>> to namespaceMap : Map<N,Map<K,S>> in method private writeStateTableForKeyGroup(outView DataOutputView, stateTable StateTable<K,N,S>, keyGroupIndex int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type stateSerializer : TypeSerializer to stateSerializer : TypeSerializer<S> in method private readStateTableForKeyGroup(inView DataInputView, stateTable StateTable<K,N,S>, keyGroupIndex int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type value : Object to state : S in method private readStateTableForKeyGroup(inView DataInputView, stateTable StateTable<K,N,S>, keyGroupIndex int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type entryMap : Map<K,?> to entryMap : Map<K,S> in method private writeStateTableForKeyGroup(outView DataOutputView, stateTable StateTable<K,N,S>, keyGroupIndex int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type entryMap : Map to entryMap : Map<K,S> in method private readStateTableForKeyGroup(inView DataInputView, stateTable StateTable<K,N,S>, keyGroupIndex int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type namespace : Map.Entry<?,? extends Map<K,?>> to namespace : Map.Entry<N,Map<K,S>> in method private writeStateTableForKeyGroup(outView DataOutputView, stateTable StateTable<K,N,S>, keyGroupIndex int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type namespaceMap : Map to namespaceMap : Map<N,Map<K,S>> in method private readStateTableForKeyGroup(inView DataInputView, stateTable StateTable<K,N,S>, keyGroupIndex int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type stateSerializer : TypeSerializer to stateSerializer : TypeSerializer<?> in method private restorePartitionedState(state List<KeyGroupsStateHandle>) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type namespaceSerializer : TypeSerializer to namespaceSerializer : TypeSerializer<?> in method private restorePartitionedState(state List<KeyGroupsStateHandle>) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type namespaceSerializer : TypeSerializer to namespaceSerializer : TypeSerializer<N> in method private readStateTableForKeyGroup(inView DataInputView, stateTable StateTable<K,N,S>, keyGroupIndex int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type namespaceSerializer : TypeSerializer to namespaceSerializer : TypeSerializer<?> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory) : RunnableFuture<KeyGroupsStateHandle> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type stateSerializer : TypeSerializer to stateSerializer : TypeSerializer<?> in method public snapshot(checkpointId long, timestamp long, streamFactory CheckpointStreamFactory) : RunnableFuture<KeyGroupsStateHandle> in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type namespace : Object to namespace : N in method private readStateTableForKeyGroup(inView DataInputView, stateTable StateTable<K,N,S>, keyGroupIndex int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type key : Object to key : K in method private readStateTableForKeyGroup(inView DataInputView, stateTable StateTable<K,N,S>, keyGroupIndex int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type stateSerializer : TypeSerializer to stateSerializer : TypeSerializer<S> in method private writeStateTableForKeyGroup(outView DataOutputView, stateTable StateTable<K,N,S>, keyGroupIndex int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |
|
Change Variable Type entry : Map.Entry<K,?> to entry : Map.Entry<K,S> in method private writeStateTableForKeyGroup(outView DataOutputView, stateTable StateTable<K,N,S>, keyGroupIndex int) : void in class org.apache.flink.runtime.state.heap.HeapKeyedStateBackend |
From |
To |