Package | Description |
---|---|
org.apache.flink.runtime.checkpoint |
Modifier and Type | Class and Description |
---|---|
class |
MappingBasedRepartitioner<T>
A repartitioner that assigns the same channel state to multiple subtasks according to some
mapping.
|
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> Map<OperatorInstanceID,List<T>> |
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(Map<OperatorID,OperatorState> oldOperatorStates,
int newParallelism,
java.util.function.Function<OperatorSubtaskState,StateObjectCollection<T>> extractHandle,
OperatorStateRepartitioner<T> stateRepartitioner,
Map<OperatorInstanceID,List<T>> result) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.