@Internal public interface OperatorStateRepartitioner
Modifier and Type | Method and Description |
---|---|
List<List<OperatorStateHandle>> |
repartitionState(List<List<OperatorStateHandle>> previousParallelSubtaskStates,
int oldParallelism,
int newParallelism) |
List<List<OperatorStateHandle>> repartitionState(List<List<OperatorStateHandle>> previousParallelSubtaskStates, int oldParallelism, int newParallelism)
previousParallelSubtaskStates
- List with one entry of state handles per parallel subtask of an operator, as they
have been checkpointed.oldParallelism
- The parallelism before we start redistribution.newParallelism
- The parallelism that we consider for the state redistribution. Determines the size of the
returned list.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.