Package | Description |
---|---|
org.apache.flink.runtime.deployment | |
org.apache.flink.runtime.executiongraph |
Modifier and Type | Method and Description |
---|---|
static ShuffleDescriptor |
TaskDeploymentDescriptorFactory.getConsumedPartitionShuffleDescriptor(ExecutionEdge edge,
boolean allowUnknownPartitions) |
Modifier and Type | Method and Description |
---|---|
ExecutionEdge[][] |
ExecutionVertex.getAllInputEdges() |
ExecutionEdge[] |
ExecutionVertex.getInputEdges(int input) |
Modifier and Type | Method and Description |
---|---|
List<List<ExecutionEdge>> |
IntermediateResultPartition.getConsumers() |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.