Package org.apache.flink.runtime.executiongraph

Class ExecutionVertexInputInfo

java.lang.Object

org.apache.flink.runtime.executiongraph.ExecutionVertexInputInfo

All Implemented Interfaces:

Serializable

public class ExecutionVertexInputInfo
extends Object
implements Serializable

This class describe the inputs(partitions and subpartitions that belong to the same intermediate result) information of an execution vertex.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ExecutionVertexInputInfo(int subtaskIndex, IndexRange partitionIndexRange, IndexRange subpartitionIndexRange)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object obj)
IndexRange	getPartitionIndexRange()	Get the partition range this subtask should consume.
IndexRange	getSubpartitionIndexRange()	Get the subpartition range this subtask should consume.
int	getSubtaskIndex()	Get the index of this subtask.

Methods inherited from class java.lang.Object

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

Constructor Detail

ExecutionVertexInputInfo

public ExecutionVertexInputInfo(int subtaskIndex,
                                IndexRange partitionIndexRange,
                                IndexRange subpartitionIndexRange)

Method Detail

getSubpartitionIndexRange

public IndexRange getSubpartitionIndexRange()

Get the subpartition range this subtask should consume.

getPartitionIndexRange

public IndexRange getPartitionIndexRange()

Get the partition range this subtask should consume.

getSubtaskIndex

public int getSubtaskIndex()

Get the index of this subtask.

equals

public boolean equals(Object obj)

Overrides:

equals in class Object