Package | Description |
---|---|
org.apache.flink.runtime.deployment | |
org.apache.flink.runtime.executiongraph |
Modifier and Type | Method and Description |
---|---|
static PartialInputChannelDeploymentDescriptor |
PartialInputChannelDeploymentDescriptor.fromEdge(IntermediateResultPartition partition,
Execution producer)
Creates a partial input channel for the given partition and producing task.
|
Modifier and Type | Method and Description |
---|---|
void |
ExecutionVertex.cachePartitionInfo(PartialInputChannelDeploymentDescriptor partitionInfo) |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.