public class RoundRobinOperatorStateRepartitioner extends Object implements OperatorStateRepartitioner
OperatorStateRepartitioner
that redistributes state in round robin fashion.Modifier and Type | Field and Description |
---|---|
static OperatorStateRepartitioner |
INSTANCE |
Constructor and Description |
---|
RoundRobinOperatorStateRepartitioner() |
Modifier and Type | Method and Description |
---|---|
List<Collection<OperatorStateHandle>> |
repartitionState(List<OperatorStateHandle> previousParallelSubtaskStates,
int parallelism) |
public static final OperatorStateRepartitioner INSTANCE
public RoundRobinOperatorStateRepartitioner()
public List<Collection<OperatorStateHandle>> repartitionState(List<OperatorStateHandle> previousParallelSubtaskStates, int parallelism)
repartitionState
in interface OperatorStateRepartitioner
previousParallelSubtaskStates
- List of state handles to the parallel subtask states of an operator, as they
have been checkpointed.parallelism
- The parallelism that we consider for the state redistribution. Determines the size of the
returned list.Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.