org.apache.flink.runtime.executiongraph

Class EdgeManager

java.lang.Object

org.apache.flink.runtime.executiongraph.EdgeManager

public class EdgeManager
extends Object

Class that manages all the connections between tasks.

Constructor Summary

Constructors

Constructor and Description
EdgeManager()

Method Summary

Modifier and Type	Method and Description
void	connectPartitionWithConsumerVertexGroup(IntermediateResultPartitionID resultPartitionId, ConsumerVertexGroup consumerVertexGroup)
void	connectVertexWithConsumedPartitionGroup(ExecutionVertexID executionVertexId, ConsumedPartitionGroup consumedPartitionGroup)
List<ConsumedPartitionGroup>	getConsumedPartitionGroupsById(IntermediateResultPartitionID resultPartitionId)
List<ConsumedPartitionGroup>	getConsumedPartitionGroupsForVertex(ExecutionVertexID executionVertexId)
List<ConsumerVertexGroup>	getConsumerVertexGroupsForPartition(IntermediateResultPartitionID resultPartitionId)
int	getNumberOfConsumedPartitionGroupsById(IntermediateResultPartitionID resultPartitionId)
void	registerConsumedPartitionGroup(ConsumedPartitionGroup group)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EdgeManager

public EdgeManager()

Method Detail

connectPartitionWithConsumerVertexGroup

public void connectPartitionWithConsumerVertexGroup(IntermediateResultPartitionID resultPartitionId,
                                                    ConsumerVertexGroup consumerVertexGroup)

connectVertexWithConsumedPartitionGroup

public void connectVertexWithConsumedPartitionGroup(ExecutionVertexID executionVertexId,
                                                    ConsumedPartitionGroup consumedPartitionGroup)

getConsumerVertexGroupsForPartition

public List<ConsumerVertexGroup> getConsumerVertexGroupsForPartition(IntermediateResultPartitionID resultPartitionId)

getConsumedPartitionGroupsForVertex

public List<ConsumedPartitionGroup> getConsumedPartitionGroupsForVertex(ExecutionVertexID executionVertexId)

registerConsumedPartitionGroup

public void registerConsumedPartitionGroup(ConsumedPartitionGroup group)

getConsumedPartitionGroupsById

public List<ConsumedPartitionGroup> getConsumedPartitionGroupsById(IntermediateResultPartitionID resultPartitionId)

getNumberOfConsumedPartitionGroupsById

public int getNumberOfConsumedPartitionGroupsById(IntermediateResultPartitionID resultPartitionId)