Package | Description |
---|---|
org.apache.flink.runtime.checkpoint |
Modifier and Type | Field and Description |
---|---|
static RescaledChannelsMapping |
RescaledChannelsMapping.NO_CHANNEL_MAPPING |
Modifier and Type | Field and Description |
---|---|
static Map<Integer,RescaledChannelsMapping> |
InflightDataRescalingDescriptor.NO_MAPPINGS |
Modifier and Type | Method and Description |
---|---|
RescaledChannelsMapping |
InflightDataRescalingDescriptor.getChannelMapping(int gateOrPartitionIndex) |
Constructor and Description |
---|
InflightDataRescalingDescriptor(Set<Integer> oldSubtaskIndexes,
Map<Integer,RescaledChannelsMapping> rescaledChannelsMappings) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.