Package org.apache.flink.runtime.io.network.partition.hybrid

Interface HsMemoryDataManagerOperation

All Known Implementing Classes:

HsMemoryDataManager

public interface HsMemoryDataManagerOperation

This interface is used by HsSubpartitionMemoryDataManager to operate HsMemoryDataManager. Spilling decision may be made and handled inside these operations.

Method Summary

Modifier and Type	Method	Description
void	markBufferReleasedFromFile(int subpartitionId, int bufferIndex)	This method is called when buffer should mark as released in HsFileDataIndex.
void	onBufferConsumed(BufferIndexAndChannel consumedBuffer)	This method is called when buffer is consumed.
void	onBufferFinished()	This method is called when buffer is finished.
void	onConsumerReleased(int subpartitionId, HsConsumerId consumerId)	This method is called when consumer is decided to released.
void	onDataAvailable(int subpartitionId, Collection<HsConsumerId> consumerIds)	This method is called when subpartition data become available.
BufferBuilder	requestBufferFromPool()	Request buffer from buffer pool.

Method Detail

requestBufferFromPool

BufferBuilder requestBufferFromPool()
                             throws InterruptedException

Request buffer from buffer pool.

Returns:

requested buffer.

Throws:

InterruptedException

markBufferReleasedFromFile

void markBufferReleasedFromFile(int subpartitionId,
                                int bufferIndex)

This method is called when buffer should mark as released in HsFileDataIndex.

Parameters:

subpartitionId - the subpartition that target buffer belong to.

bufferIndex - index of buffer to mark as released.

onBufferConsumed

void onBufferConsumed(BufferIndexAndChannel consumedBuffer)

This method is called when buffer is consumed.

Parameters:

consumedBuffer - target buffer to mark as consumed.

onBufferFinished

void onBufferFinished()

This method is called when buffer is finished.

onDataAvailable

void onDataAvailable(int subpartitionId,
                     Collection<HsConsumerId> consumerIds)

This method is called when subpartition data become available.

Parameters:

subpartitionId - the subpartition's identifier that this consumer belongs to.

consumerIds - the consumer's identifier which need notify data available.

onConsumerReleased

void onConsumerReleased(int subpartitionId,
                        HsConsumerId consumerId)

This method is called when consumer is decided to released.

Parameters:

subpartitionId - the subpartition's identifier that this consumer belongs to.

consumerId - the consumer's identifier which decided to be released.