public interface OperatorStateRepartitioner
List<Collection<OperatorStateHandle>> repartitionState(List<OperatorStateHandle> previousParallelSubtaskStates, int newParallelism)
previousParallelSubtaskStates- List of state handles to the parallel subtask states of an operator, as they have been checkpointed.
newParallelism- The parallelism that we consider for the state redistribution. Determines the size of the returned list.
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.