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

Packages that use BufferAvailabilityListener

Package	Description
org.apache.flink.runtime.io.network.api.writer
org.apache.flink.runtime.io.network.partition
org.apache.flink.runtime.io.network.partition.consumer
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 BufferAvailabilityListener in org.apache.flink.runtime.io.network.api.writer

Methods in org.apache.flink.runtime.io.network.api.writer with parameters of type BufferAvailabilityListener

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

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

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

Modifier and Type	Method	Description
PipelinedSubpartitionView	PipelinedApproximateSubpartition.createReadView(BufferAvailabilityListener availabilityListener)	To simply the view releasing threading model, PipelinedApproximateSubpartition.releaseView() is called only before creating a new view.
PipelinedSubpartitionView	PipelinedSubpartition.createReadView(BufferAvailabilityListener availabilityListener)
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)

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

Constructor	Description
PipelinedSubpartitionView(PipelinedSubpartition parent, BufferAvailabilityListener listener)

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

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

Modifier and Type	Class	Description
class	LocalInputChannel	An input channel, which requests a local subpartition.

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

Methods in org.apache.flink.runtime.io.network.partition.hybrid with parameters of type BufferAvailabilityListener

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

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

Constructor	Description
HsSubpartitionConsumer(BufferAvailabilityListener availabilityListener)

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

Methods in org.apache.flink.runtime.io.network.partition.hybrid.tiered.netty with parameters of type BufferAvailabilityListener

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

Constructors in org.apache.flink.runtime.io.network.partition.hybrid.tiered.netty with parameters of type BufferAvailabilityListener

Constructor	Description
NettyConnectionWriterImpl(NettyPayloadManager nettyPayloadManager, BufferAvailabilityListener availabilityListener)
TieredStorageResultSubpartitionView(BufferAvailabilityListener availabilityListener, List<NettyPayloadManager> nettyPayloadManagers, List<NettyConnectionId> nettyConnectionIds, List<NettyServiceProducer> serviceProducers)

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

Methods in org.apache.flink.runtime.io.network.partition.hybrid.tiered.shuffle with parameters of type BufferAvailabilityListener

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