Uses of Class
org.apache.flink.runtime.jobgraph.JobEdge

Packages that use JobEdge

Package	Description
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.jobgraph

Uses of JobEdge in org.apache.flink.runtime.executiongraph

Methods in org.apache.flink.runtime.executiongraph with parameters of type JobEdge

Modifier and Type	Method and Description
void	ExecutionVertex.connectSource(int inputNumber, IntermediateResult source, JobEdge edge, int consumerNumber)

Uses of JobEdge in org.apache.flink.runtime.jobgraph

Methods in org.apache.flink.runtime.jobgraph that return JobEdge

Modifier and Type	Method and Description
JobEdge	JobVertex.connectDataSetAsInput(IntermediateDataSet dataSet, DistributionPattern distPattern)
JobEdge	JobVertex.connectNewDataSetAsInput(JobVertex input, DistributionPattern distPattern, ResultPartitionType partitionType)

Methods in org.apache.flink.runtime.jobgraph that return types with arguments of type JobEdge

Modifier and Type	Method and Description
List<JobEdge>	IntermediateDataSet.getConsumers()
List<JobEdge>	JobVertex.getInputs()

Methods in org.apache.flink.runtime.jobgraph with parameters of type JobEdge

Modifier and Type	Method and Description
void	IntermediateDataSet.addConsumer(JobEdge edge)