|
Change Return Type List<Collection<OperatorStateHandle>> to List<List<OperatorStateHandle>> in method public repartitionState(previousParallelSubtaskStates List<OperatorStateHandle>, newParallelism int) : List<List<OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.OperatorStateRepartitioner |
From |
To |
|
Change Return Type Tuple2<Collection<KeyedStateHandle>,Collection<KeyedStateHandle>> to Tuple2<List<KeyedStateHandle>,List<KeyedStateHandle>> in method private reAssignSubKeyedStates(operatorState OperatorState, keyGroupPartitions List<KeyGroupRange>, subTaskIndex int, newParallelism int, oldParallelism int) : Tuple2<List<KeyedStateHandle>,List<KeyedStateHandle>> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Return Type List<Collection<OperatorStateHandle>> to List<List<OperatorStateHandle>> in method public applyRepartitioner(opStateRepartitioner OperatorStateRepartitioner, chainOpParallelStates List<OperatorStateHandle>, oldParallelism int, newParallelism int) : List<List<OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Return Type List<Collection<OperatorStateHandle>> to List<List<OperatorStateHandle>> in method public repartitionState(previousParallelSubtaskStates List<OperatorStateHandle>, newParallelism int) : List<List<OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Change Variable Type result : List<Collection<OperatorStateHandle>> to result : List<List<OperatorStateHandle>> in method public repartitionState(previousParallelSubtaskStates List<OperatorStateHandle>, newParallelism int) : List<List<OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.RoundRobinOperatorStateRepartitioner |
From |
To |
|
Change Variable Type repackStream : List<Collection<OperatorStateHandle>> to repackStream : List<List<OperatorStateHandle>> in method public applyRepartitioner(opStateRepartitioner OperatorStateRepartitioner, chainOpParallelStates List<OperatorStateHandle>, oldParallelism int, newParallelism int) : List<List<OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type states : List<Collection<OperatorStateHandle>> to states : List<List<OperatorStateHandle>> in method public applyRepartitioner(operatorID OperatorID, opStateRepartitioner OperatorStateRepartitioner, chainOpParallelStates List<OperatorStateHandle>, oldParallelism int, newParallelism int) : Map<OperatorInstanceID,List<OperatorStateHandle>> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type subRawKeyedState : Collection<KeyedStateHandle> to subRawKeyedState : List<KeyedStateHandle> in method private reAssignSubKeyedStates(operatorState OperatorState, keyGroupPartitions List<KeyGroupRange>, subTaskIndex int, newParallelism int, oldParallelism int) : Tuple2<List<KeyedStateHandle>,List<KeyedStateHandle>> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type pshs : List<Collection<OperatorStateHandle>> to pshs : List<List<OperatorStateHandle>> in method private doTestPartitionableStateRepartitioning(r Random, oldParallelism int, newParallelism int, numNamedStates int, maxPartitionsPerState int) : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type subManagedKeyedState : Collection<KeyedStateHandle> to subManagedKeyedState : List<KeyedStateHandle> in method private reAssignSubKeyedStates(operatorState OperatorState, keyGroupPartitions List<KeyGroupRange>, subTaskIndex int, newParallelism int, oldParallelism int) : Tuple2<List<KeyedStateHandle>,List<KeyedStateHandle>> in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |
|
Change Variable Type repartitionedStates : List<Collection<OperatorStateHandle>> to repartitionedStates : List<List<OperatorStateHandle>> in method public testReplicateModeStateHandle() : void in class org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest |
From |
To |
|
Change Variable Type subKeyedStates : Tuple2<Collection<KeyedStateHandle>,Collection<KeyedStateHandle>> to subKeyedStates : Tuple2<List<KeyedStateHandle>,List<KeyedStateHandle>> in method private reDistributeKeyedStates(oldOperatorStates List<OperatorState>, newParallelism int, newOperatorIDs List<OperatorID>, newKeyGroupPartitions List<KeyGroupRange>, newManagedKeyedState Map<OperatorInstanceID,List<KeyedStateHandle>>, newRawKeyedState Map<OperatorInstanceID,List<KeyedStateHandle>>) : void in class org.apache.flink.runtime.checkpoint.StateAssignmentOperation |
From |
To |