@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 |
---|
MappingBasedRepartitioner(RescaleMappings newToOldSubtasksMapping) |
Modifier and Type | Method and Description |
---|---|
List<List<T>> |
repartitionState(List<List<T>> previousParallelSubtaskStates,
int oldParallelism,
int newParallelism) |
public MappingBasedRepartitioner(RescaleMappings newToOldSubtasksMapping)
public List<List<T>> repartitionState(List<List<T>> previousParallelSubtaskStates, int oldParallelism, int newParallelism)
repartitionState
in interface OperatorStateRepartitioner<T>
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–2024 The Apache Software Foundation. All rights reserved.