Package | Description |
---|---|
org.apache.flink.runtime.checkpoint |
Modifier and Type | Class and Description |
---|---|
class |
RoundRobinOperatorStateRepartitioner
Current default implementation of
OperatorStateRepartitioner that redistributes state in
round robin fashion. |
Modifier and Type | Field and Description |
---|---|
static OperatorStateRepartitioner<OperatorStateHandle> |
RoundRobinOperatorStateRepartitioner.INSTANCE |
Modifier and Type | Method and Description |
---|---|
static <T extends StateObject> |
StateAssignmentOperation.applyRepartitioner(OperatorID operatorID,
OperatorStateRepartitioner<T> opStateRepartitioner,
List<List<T>> chainOpParallelStates,
int oldParallelism,
int newParallelism) |
static <T> List<List<T>> |
StateAssignmentOperation.applyRepartitioner(OperatorStateRepartitioner<T> opStateRepartitioner,
List<List<T>> chainOpParallelStates,
int oldParallelism,
int newParallelism)
Repartitions the given operator state using the given
OperatorStateRepartitioner with
respect to the new parallelism. |
static <T extends StateObject> |
StateAssignmentOperation.reDistributePartitionableStates(List<OperatorState> oldOperatorStates,
int newParallelism,
List<OperatorIDPair> newOperatorIDs,
java.util.function.Function<OperatorSubtaskState,StateObjectCollection<T>> extractHandle,
OperatorStateRepartitioner<T> stateRepartitioner) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.