Uses of Class
org.apache.flink.runtime.executiongraph.IndexRange
-
-
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
Subclasses of IndexRange in org.apache.flink.runtime.io.network.partition Modifier and Type Class Description class
ResultSubpartitionIndexSet
A collection of subpartition indexes.Constructors in org.apache.flink.runtime.io.network.partition with parameters of type IndexRange Constructor 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 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)
-