| 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 |