Uses of Interface
org.apache.flink.runtime.io.network.partition.PartitionProducerStateProvider

Packages that use PartitionProducerStateProvider

Package	Description
org.apache.flink.runtime.io.network
org.apache.flink.runtime.io.network.partition.consumer
org.apache.flink.runtime.shuffle
org.apache.flink.runtime.taskmanager

Uses of PartitionProducerStateProvider in org.apache.flink.runtime.io.network

Methods in org.apache.flink.runtime.io.network with parameters of type PartitionProducerStateProvider

Modifier and Type	Method and Description
List<SingleInputGate>	NettyShuffleEnvironment.createInputGates(ShuffleIOOwnerContext ownerContext, PartitionProducerStateProvider partitionProducerStateProvider, List<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors)

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

Methods in org.apache.flink.runtime.io.network.partition.consumer with parameters of type PartitionProducerStateProvider

Modifier and Type	Method and Description
SingleInputGate	SingleInputGateFactory.create(ShuffleIOOwnerContext owner, int gateIndex, InputGateDeploymentDescriptor igdd, PartitionProducerStateProvider partitionProducerStateProvider, InputChannelMetrics metrics) Creates an input gate and all of its input channels.

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

Constructor and Description

SingleInputGate(String owningTaskName, int gateIndex, IntermediateDataSetID consumedResultId, ResultPartitionType consumedPartitionType, SubpartitionIndexRange subpartitionIndexRange, int numberOfInputChannels, PartitionProducerStateProvider partitionProducerStateProvider, SupplierWithException<BufferPool,IOException> bufferPoolFactory, BufferDecompressor bufferDecompressor, MemorySegmentProvider memorySegmentProvider, int segmentSize, ThroughputCalculator throughputCalculator, BufferDebloater bufferDebloater)

Uses of PartitionProducerStateProvider in org.apache.flink.runtime.shuffle

Methods in org.apache.flink.runtime.shuffle with parameters of type PartitionProducerStateProvider

Modifier and Type	Method and Description
List<G>	ShuffleEnvironment.createInputGates(ShuffleIOOwnerContext ownerContext, PartitionProducerStateProvider partitionProducerStateProvider, List<InputGateDeploymentDescriptor> inputGateDeploymentDescriptors) Factory method for the InputGates to consume result partitions.

Uses of PartitionProducerStateProvider in org.apache.flink.runtime.taskmanager

Classes in org.apache.flink.runtime.taskmanager that implement PartitionProducerStateProvider

Modifier and Type	Class and Description
class	Task The Task represents one execution of a parallel subtask on a TaskManager.