Package | Description |
---|---|
org.apache.flink.runtime.deployment | |
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.shuffle |
Modifier and Type | Method and Description |
---|---|
static ShuffleDescriptor |
TaskDeploymentDescriptorFactory.getConsumedPartitionShuffleDescriptor(ExecutionEdge edge,
boolean allowUnknownPartitions) |
ShuffleDescriptor |
ResultPartitionDeploymentDescriptor.getShuffleDescriptor() |
ShuffleDescriptor[] |
InputGateDeploymentDescriptor.getShuffleDescriptors() |
Constructor and Description |
---|
InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId,
ResultPartitionType consumedPartitionType,
int consumedSubpartitionIndex,
ShuffleDescriptor[] inputChannels) |
ResultPartitionDeploymentDescriptor(PartitionDescriptor partitionDescriptor,
ShuffleDescriptor shuffleDescriptor,
int maxParallelism,
boolean sendScheduleOrUpdateConsumersMessage) |
Modifier and Type | Method and Description |
---|---|
ShuffleDescriptor |
PartitionInfo.getShuffleDescriptor() |
Constructor and Description |
---|
PartitionInfo(IntermediateDataSetID intermediateResultPartitionID,
ShuffleDescriptor shuffleDescriptor) |
Modifier and Type | Interface and Description |
---|---|
interface |
ShuffleMaster<T extends ShuffleDescriptor>
Intermediate result partition registry to use in
JobMaster . |
interface |
ShuffleServiceFactory<SD extends ShuffleDescriptor,P extends ResultPartitionWriter,G extends IndexedInputGate>
Interface for shuffle service factory implementations.
|
Modifier and Type | Class and Description |
---|---|
class |
NettyShuffleDescriptor
Default implementation of
ShuffleDescriptor for NettyShuffleMaster . |
class |
UnknownShuffleDescriptor
Unknown
ShuffleDescriptor for which the producer has not been deployed yet. |
Modifier and Type | Method and Description |
---|---|
static <T,SD extends ShuffleDescriptor> |
ShuffleUtils.applyWithShuffleTypeCheck(Class<SD> shuffleDescriptorClass,
ShuffleDescriptor shuffleDescriptor,
java.util.function.Function<UnknownShuffleDescriptor,T> functionOfUnknownDescriptor,
java.util.function.Function<SD,T> functionOfKnownDescriptor)
Apply different functions to known and unknown
ShuffleDescriptor s. |
Modifier and Type | Method and Description |
---|---|
static <T,SD extends ShuffleDescriptor> |
ShuffleUtils.applyWithShuffleTypeCheck(Class<SD> shuffleDescriptorClass,
ShuffleDescriptor shuffleDescriptor,
java.util.function.Function<UnknownShuffleDescriptor,T> functionOfUnknownDescriptor,
java.util.function.Function<SD,T> functionOfKnownDescriptor)
Apply different functions to known and unknown
ShuffleDescriptor s. |
void |
ShuffleMaster.releasePartitionExternally(ShuffleDescriptor shuffleDescriptor)
Release any external resources occupied by the given partition.
|
void |
NettyShuffleMaster.releasePartitionExternally(ShuffleDescriptor shuffleDescriptor) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.