Uses of Class
org.apache.flink.runtime.executiongraph.IndexRange

Packages that use IndexRange

Package	Description
org.apache.flink.runtime.deployment
org.apache.flink.runtime.executiongraph
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.scheduler.adaptivebatch

Uses of IndexRange in org.apache.flink.runtime.deployment

Methods in org.apache.flink.runtime.deployment that return IndexRange

Modifier and Type	Method and Description
IndexRange	InputGateDeploymentDescriptor.getConsumedSubpartitionIndexRange() Return the index range of the consumed subpartitions.

Constructors in org.apache.flink.runtime.deployment with parameters of type IndexRange

Constructor and Description
InputGateDeploymentDescriptor(IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, IndexRange consumedSubpartitionIndexRange, int numberOfInputChannels, List<TaskDeploymentDescriptor.MaybeOffloaded<TaskDeploymentDescriptorFactory.ShuffleDescriptorGroup>> serializedInputChannels)

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

Methods in org.apache.flink.runtime.executiongraph that return IndexRange

Modifier and Type	Method and Description
IndexRange	ExecutionVertexInputInfo.getPartitionIndexRange() Get the partition range this subtask should consume.
IndexRange	ExecutionVertexInputInfo.getSubpartitionIndexRange() Get the subpartition range this subtask should consume.

Constructors in org.apache.flink.runtime.executiongraph with parameters of type IndexRange

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

Uses of IndexRange in org.apache.flink.runtime.io.network.partition

Subclasses of IndexRange in org.apache.flink.runtime.io.network.partition

Modifier and Type	Class and Description
class	ResultSubpartitionIndexSet A collection of subpartition indexes.

Constructors in org.apache.flink.runtime.io.network.partition with parameters of type IndexRange

Constructor and Description
ResultSubpartitionIndexSet(IndexRange indexRange)

Uses of IndexRange in org.apache.flink.runtime.scheduler.adaptivebatch

Methods in org.apache.flink.runtime.scheduler.adaptivebatch with parameters of type IndexRange

Modifier and Type	Method and Description
long	PointwiseBlockingResultInfo.getNumBytesProduced(IndexRange partitionIndexRange, IndexRange subpartitionIndexRange)
long	AllToAllBlockingResultInfo.getNumBytesProduced(IndexRange partitionIndexRange, IndexRange subpartitionIndexRange)
long	BlockingResultInfo.getNumBytesProduced(IndexRange partitionIndexRange, IndexRange subpartitionIndexRange) Return the aggregated num of bytes according to the index range for partition and subpartition.