Package | Description |
---|---|
org.apache.flink.runtime.checkpoint | |
org.apache.flink.runtime.io.network.api.writer |
Modifier and Type | Field and Description |
---|---|
static RescaleMappings |
RescaleMappings.SYMMETRIC_IDENTITY |
Modifier and Type | Method and Description |
---|---|
RescaleMappings |
InflightDataRescalingDescriptor.getChannelMapping(int gateOrPartitionIndex) |
static RescaleMappings |
RescaleMappings.identity(int numberOfSources,
int numberOfTargets) |
RescaleMappings |
RescaleMappings.invert() |
static RescaleMappings |
RescaleMappings.of(java.util.stream.Stream<int[]> mappedTargets,
int numberOfTargets) |
Constructor and Description |
---|
InflightDataGateOrPartitionRescalingDescriptor(int[] oldSubtaskIndexes,
RescaleMappings rescaledChannelsMappings,
Set<Integer> ambiguousSubtaskIndexes,
InflightDataRescalingDescriptor.InflightDataGateOrPartitionRescalingDescriptor.MappingType mappingType) |
MappingBasedRepartitioner(RescaleMappings newToOldSubtasksMapping) |
Modifier and Type | Method and Description |
---|---|
RescaleMappings |
SubtaskStateMapper.getNewToOldSubtasksMapping(int oldParallelism,
int newParallelism)
Returns a mapping new subtask index to all old subtask indexes.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.