List<List<OperatorStateHandle>> pshs=repartitioner.repartitionState(previousParallelOpInstanceStates,newParallelism); | List<List<OperatorStateHandle>> pshs=repartitioner.repartitionState(previousParallelOpInstanceStates,oldParallelism,newParallelism); | repartitioner.repartitionState(previousParallelOpInstanceStates,newParallelism) | repartitioner.repartitionState(previousParallelOpInstanceStates,oldParallelism,newParallelism) | flink | bdb776035f7266916e9debc7a0d4e7cc5cb1dfd3 | org.apache.flink.runtime.checkpoint.CheckpointCoordinatorTest | | _1 | previousParallelOpInstanceStates |
---|
_2 | previousParallelOpInstanceStates |
---|
| TCIVar | previousParallelOpInstanceStates |
---|
v0 | repartitioner |
---|
v2 | newParallelism |
---|
| | TCIVar | previousParallelOpInstanceStates |
---|
v0 | repartitioner |
---|
v2 | newParallelism |
---|
| Uses | False |