@NotThreadSafe public class MappingBasedRepartitioner<T> extends Object implements OperatorStateRepartitioner<T>
The replicated data will then be filtered before processing the record.
Note that channel mappings are cached for the same parallelism changes.
|Constructor and Description|
|Modifier and Type||Method and Description|
public MappingBasedRepartitioner(RescaleMappings newToOldSubtasksMapping)
public List<List<T>> repartitionState(List<List<T>> 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–2022 The Apache Software Foundation. All rights reserved.