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

Packages that use ResultSubpartitionView

Package	Description
org.apache.flink.runtime.io.network.api.writer
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.io.network.partition.hybrid
org.apache.flink.runtime.io.network.partition.hybrid.tiered.netty
org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle

Uses of ResultSubpartitionView in org.apache.flink.runtime.io.network.api.writer

Methods in org.apache.flink.runtime.io.network.api.writer that return ResultSubpartitionView

Modifier and Type	Method	Description
ResultSubpartitionView	ResultPartitionWriter.createSubpartitionView(int index, BufferAvailabilityListener availabilityListener)	Returns a reader for the subpartition with the given index.

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

Classes in org.apache.flink.runtime.io.network.partition that implement ResultSubpartitionView

Modifier and Type	Class	Description
class	BoundedBlockingSubpartitionDirectTransferReader	The reader (read view) of a BoundedBlockingSubpartition based on FileRegion.
class	NoOpResultSubpartitionView	A dummy implementation of the ResultSubpartitionView.
class	PipelinedApproximateSubpartitionView	View over a pipelined in-memory only subpartition allowing reconnecting.
class	PipelinedSubpartitionView	View over a pipelined in-memory only subpartition.

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

Modifier and Type	Method	Description
abstract ResultSubpartitionView	ResultSubpartition.createReadView(BufferAvailabilityListener availabilityListener)
ResultSubpartitionView	BufferWritingResultPartition.createSubpartitionView(int subpartitionIndex, BufferAvailabilityListener availabilityListener)
ResultSubpartitionView	ResultPartitionManager.createSubpartitionView(ResultPartitionID partitionId, int subpartitionIndex, BufferAvailabilityListener availabilityListener)
ResultSubpartitionView	ResultPartitionProvider.createSubpartitionView(ResultPartitionID partitionId, int index, BufferAvailabilityListener availabilityListener)	Returns the requested intermediate result partition input view.
ResultSubpartitionView	SortMergeResultPartition.createSubpartitionView(int subpartitionIndex, BufferAvailabilityListener availabilityListener)

Uses of ResultSubpartitionView in org.apache.flink.runtime.io.network.partition.hybrid

Classes in org.apache.flink.runtime.io.network.partition.hybrid that implement ResultSubpartitionView

Modifier and Type	Class	Description
class	HsSubpartitionConsumer	The read view of HsResultPartition, data can be read from memory or disk.

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

Modifier and Type	Method	Description
ResultSubpartitionView	HsResultPartition.createSubpartitionView(int subpartitionId, BufferAvailabilityListener availabilityListener)

Uses of ResultSubpartitionView in org.apache.flink.runtime.io.network.partition.hybrid.tiered.netty

Classes in org.apache.flink.runtime.io.network.partition.hybrid.tiered.netty that implement ResultSubpartitionView

Modifier and Type	Class	Description
class	TieredStorageResultSubpartitionView	The TieredStorageResultSubpartitionView is the implementation of ResultSubpartitionView of TieredResultPartition.

Methods in org.apache.flink.runtime.io.network.partition.hybrid.tiered.netty that return ResultSubpartitionView

Modifier and Type	Method	Description
ResultSubpartitionView	TieredStorageNettyServiceImpl.createResultSubpartitionView(TieredStoragePartitionId partitionId, TieredStorageSubpartitionId subpartitionId, BufferAvailabilityListener availabilityListener)	Create a ResultSubpartitionView for the netty server.

Uses of ResultSubpartitionView in org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle

Methods in org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle that return ResultSubpartitionView

Modifier and Type	Method	Description
ResultSubpartitionView	TieredResultPartition.createSubpartitionView(int subpartitionId, BufferAvailabilityListener availabilityListener)