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

Class BufferManager

java.lang.Object

org.apache.flink.runtime.io.network.partition.consumer.BufferManager

All Implemented Interfaces:

BufferListener, BufferRecycler

public class BufferManager
extends Object
implements BufferListener, BufferRecycler

The general buffer manager used by InputChannel to request/recycle exclusive or floating buffers.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.flink.runtime.io.network.buffer.BufferListener

BufferListener.NotificationResult

Constructor Summary

Constructors

Constructor and Description
BufferManager(MemorySegmentProvider globalPool, InputChannel inputChannel, int numRequiredBuffers)

Method Summary

Modifier and Type	Method and Description
BufferListener.NotificationResult	notifyBufferAvailable(Buffer buffer) The buffer pool notifies this listener of an available floating buffer.
void	notifyBufferDestroyed() Notification callback if the buffer provider is destroyed.
void	recycle(MemorySegment segment) Exclusive buffer is recycled to this channel manager directly and it may trigger return extra floating buffer based on numRequiredBuffers.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BufferManager

public BufferManager(MemorySegmentProvider globalPool,
                     InputChannel inputChannel,
                     int numRequiredBuffers)

Method Detail

recycle

public void recycle(MemorySegment segment)

Exclusive buffer is recycled to this channel manager directly and it may trigger return extra floating buffer based on numRequiredBuffers.

Specified by:

recycle in interface BufferRecycler

Parameters:

segment - The exclusive segment of this channel.

notifyBufferAvailable

public BufferListener.NotificationResult notifyBufferAvailable(Buffer buffer)

The buffer pool notifies this listener of an available floating buffer. If the listener is released or currently does not need extra buffers, the buffer should be returned to the buffer pool. Otherwise, the buffer will be added into the bufferQueue.

Specified by:

notifyBufferAvailable in interface BufferListener

Parameters:

buffer - Buffer that becomes available in buffer pool.

Returns:

NotificationResult indicates whether this channel accepts the buffer and is waiting for more floating buffers.

notifyBufferDestroyed

public void notifyBufferDestroyed()

Description copied from interface: BufferListener

Notification callback if the buffer provider is destroyed.

Specified by:

notifyBufferDestroyed in interface BufferListener