Uses of Class
org.apache.flink.runtime.io.network.partition.ResultPartitionManager

Packages that use ResultPartitionManager

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

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

Methods in org.apache.flink.runtime.io.network that return ResultPartitionManager

Modifier and Type	Method and Description
ResultPartitionManager	NettyShuffleEnvironment.getResultPartitionManager()

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

Modifier and Type	Method and Description
static NettyShuffleEnvironment	NettyShuffleServiceFactory.createNettyShuffleEnvironment(NettyShuffleEnvironmentConfiguration config, ResourceID taskExecutorResourceId, TaskEventPublisher taskEventPublisher, ResultPartitionManager resultPartitionManager, ConnectionManager connectionManager, MetricGroup metricGroup, Executor ioExecutor)

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

Fields in org.apache.flink.runtime.io.network.partition declared as ResultPartitionManager

Modifier and Type	Field and Description
protected ResultPartitionManager	ResultPartition.partitionManager

Methods in org.apache.flink.runtime.io.network.partition that return ResultPartitionManager

Modifier and Type	Method and Description
ResultPartitionManager	ResultPartition.getPartitionManager()

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

Constructor and Description
BoundedBlockingResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, ResultSubpartition[] subpartitions, int numTargetKeyGroups, ResultPartitionManager partitionManager, BufferCompressor bufferCompressor, SupplierWithException<BufferPool,IOException> bufferPoolFactory)
BufferWritingResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, ResultSubpartition[] subpartitions, int numTargetKeyGroups, ResultPartitionManager partitionManager, BufferCompressor bufferCompressor, SupplierWithException<BufferPool,IOException> bufferPoolFactory)
PipelinedResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, ResultSubpartition[] subpartitions, int numTargetKeyGroups, ResultPartitionManager partitionManager, BufferCompressor bufferCompressor, SupplierWithException<BufferPool,IOException> bufferPoolFactory)
ResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, int numSubpartitions, int numTargetKeyGroups, ResultPartitionManager partitionManager, BufferCompressor bufferCompressor, SupplierWithException<BufferPool,IOException> bufferPoolFactory)
ResultPartitionFactory(ResultPartitionManager partitionManager, FileChannelManager channelManager, BufferPoolFactory bufferPoolFactory, BatchShuffleReadBufferPool batchShuffleReadBufferPool, ExecutorService batchShuffleReadIOExecutor, BoundedBlockingSubpartitionType blockingSubpartitionType, int configuredNetworkBuffersPerChannel, int floatingNetworkBuffersPerGate, int networkBufferSize, boolean blockingShuffleCompressionEnabled, String compressionCodec, int maxBuffersPerChannel, int sortShuffleMinBuffers, int sortShuffleMinParallelism, boolean sslEnabled)
SortMergeResultPartition(String owningTaskName, int partitionIndex, ResultPartitionID partitionId, ResultPartitionType partitionType, int numSubpartitions, int numTargetKeyGroups, BatchShuffleReadBufferPool readBufferPool, Executor readIOExecutor, ResultPartitionManager partitionManager, String resultFileBasePath, BufferCompressor bufferCompressor, SupplierWithException<BufferPool,IOException> bufferPoolFactory)

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

Fields in org.apache.flink.runtime.io.network.partition.consumer declared as ResultPartitionManager

Modifier and Type	Field and Description
protected ResultPartitionManager	SingleInputGateFactory.partitionManager

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

Constructor and Description
LocalInputChannel(SingleInputGate inputGate, int channelIndex, ResultPartitionID partitionId, int consumedSubpartitionIndex, ResultPartitionManager partitionManager, TaskEventPublisher taskEventPublisher, int initialBackoff, int maxBackoff, Counter numBytesIn, Counter numBuffersIn, ChannelStateWriter stateWriter)
SingleInputGateFactory(ResourceID taskExecutorResourceId, NettyShuffleEnvironmentConfiguration networkConfig, ConnectionManager connectionManager, ResultPartitionManager partitionManager, TaskEventPublisher taskEventPublisher, NetworkBufferPool networkBufferPool)