Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobgraph | |
org.apache.flink.runtime.jobgraph.topology |
Modifier and Type | Method and Description |
---|---|
DistributionPattern |
IntermediateResult.getConsumingDistributionPattern() |
Modifier and Type | Method and Description |
---|---|
static int |
EdgeManagerBuildUtil.computeMaxEdgesToTargetExecutionVertex(int targetParallelism,
int sourceParallelism,
DistributionPattern distributionPattern)
Given parallelisms of two job vertices, compute the max number of edges connected to a target
execution vertex from the source execution vertices.
|
Modifier and Type | Method and Description |
---|---|
DistributionPattern |
IntermediateDataSet.getDistributionPattern() |
DistributionPattern |
JobEdge.getDistributionPattern()
Returns the distribution pattern used for this edge.
|
static DistributionPattern |
DistributionPattern.valueOf(String name)
Returns the enum constant of this type with the specified name.
|
static DistributionPattern[] |
DistributionPattern.values()
Returns an array containing the constants of this enum type, in
the order they are declared.
|
Modifier and Type | Method and Description |
---|---|
JobEdge |
JobVertex.connectNewDataSetAsInput(JobVertex input,
DistributionPattern distPattern,
ResultPartitionType partitionType) |
JobEdge |
JobVertex.connectNewDataSetAsInput(JobVertex input,
DistributionPattern distPattern,
ResultPartitionType partitionType,
boolean isBroadcast) |
JobEdge |
JobVertex.connectNewDataSetAsInput(JobVertex input,
DistributionPattern distPattern,
ResultPartitionType partitionType,
IntermediateDataSetID intermediateDataSetId,
boolean isBroadcast) |
Constructor and Description |
---|
JobEdge(IntermediateDataSet source,
JobVertex target,
DistributionPattern distributionPattern,
boolean isBroadcast)
Constructs a new job edge, that connects an intermediate result to a consumer task.
|
Modifier and Type | Method and Description |
---|---|
DistributionPattern |
LogicalEdge.getDistributionPattern()
Returns the distribution pattern used for this edge.
|
DistributionPattern |
DefaultLogicalEdge.getDistributionPattern() |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.