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.consumer
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	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	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	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	Description
ExecutionVertexInputInfo(int subtaskIndex, IndexRange partitionIndexRange, IndexRange subpartitionIndexRange)

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

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

Constructor

Description

SingleInputGate(String owningTaskName, int gateIndex, IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, IndexRange subpartitionIndexRange, int numberOfInputChannels, PartitionProducerStateProvider partitionProducerStateProvider, org.apache.flink.util.function.SupplierWithException<BufferPool,IOException> bufferPoolFactory, BufferDecompressor bufferDecompressor, org.apache.flink.core.memory.MemorySegmentProvider memorySegmentProvider, int segmentSize, ThroughputCalculator throughputCalculator, BufferDebloater bufferDebloater, TieredStorageConsumerClient tieredStorageConsumerClient, TieredStorageNettyServiceImpl nettyService, List<TieredStorageConsumerSpec> tieredStorageConsumerSpecs)

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	Description
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.
long	PointwiseBlockingResultInfo.getNumBytesProduced(IndexRange partitionIndexRange, IndexRange subpartitionIndexRange)