Package | Description |
---|---|
org.apache.flink.runtime.jobgraph |
Modifier and Type | Method and Description |
---|---|
IntermediateDataSet |
JobVertex.createAndAddResultDataSet(IntermediateDataSetID id,
ResultPartitionType partitionType) |
IntermediateDataSet |
JobVertex.createAndAddResultDataSet(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() |
Modifier and Type | Method and Description |
---|---|
void |
JobEdge.connecDataSet(IntermediateDataSet dataSet) |
JobEdge |
JobVertex.connectDataSetAsInput(IntermediateDataSet dataSet,
DistributionPattern distPattern) |
Constructor and Description |
---|
JobEdge(IntermediateDataSet source,
JobVertex target,
DistributionPattern distributionPattern)
Constructs a new job edge, that connects an intermediate result to a consumer task.
|
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.