@Internal public class RoundRobinOperatorStateRepartitioner extends Object implements OperatorStateRepartitioner<OperatorStateHandle>
OperatorStateRepartitioner
that redistributes state in
round robin fashion.Modifier and Type | Field and Description |
---|---|
static OperatorStateRepartitioner<OperatorStateHandle> |
INSTANCE |
Constructor and Description |
---|
RoundRobinOperatorStateRepartitioner() |
Modifier and Type | Method and Description |
---|---|
List<List<OperatorStateHandle>> |
repartitionState(List<List<OperatorStateHandle>> previousParallelSubtaskStates,
int oldParallelism,
int newParallelism) |
public static final OperatorStateRepartitioner<OperatorStateHandle> INSTANCE
public RoundRobinOperatorStateRepartitioner()
public List<List<OperatorStateHandle>> repartitionState(List<List<OperatorStateHandle>> previousParallelSubtaskStates, int oldParallelism, int newParallelism)
repartitionState
in interface OperatorStateRepartitioner<OperatorStateHandle>
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–2021 The Apache Software Foundation. All rights reserved.