Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.jobgraph |
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) |
Modifier and Type | Method and Description |
---|---|
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) |
Modifier and Type | Method and Description |
---|---|
static OperatorInstanceID |
OperatorInstanceID.of(int subtaskId,
OperatorID operatorID) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.