Package | Description |
---|---|
org.apache.flink.runtime.executiongraph | |
org.apache.flink.runtime.jobgraph |
Constructor and Description |
---|
IntermediateResult(IntermediateDataSet intermediateDataSet,
ExecutionJobVertex producer,
int numParallelProducers,
ResultPartitionType resultType) |
Modifier and Type | Method and Description |
---|---|
IntermediateDataSet |
JobVertex.getOrCreateResultDataSet(IntermediateDataSetID id,
ResultPartitionType partitionType) |
IntermediateDataSet |
JobEdge.getSource()
Returns the data set at the source of the edge.
|
Modifier and Type | Method and Description |
---|---|
List<IntermediateDataSet> |
JobVertex.getProducedDataSets() |
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.
|
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.