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

Packages that use DistributionPattern

Package	Description
org.apache.flink.runtime.jobgraph

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

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

Modifier and Type	Method and Description
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.

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

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

Constructors in org.apache.flink.runtime.jobgraph with parameters of type DistributionPattern

Constructor and Description
JobEdge(IntermediateDataSetID sourceId, JobVertex target, DistributionPattern distributionPattern) Constructs a new job edge that refers to an intermediate result via the Id, rather than directly through the intermediate data set structure.
JobEdge(IntermediateDataSet source, JobVertex target, DistributionPattern distributionPattern) Constructs a new job edge, that connects an intermediate result to a consumer task.