org.apache.flink.runtime.io.network.api.writer

Interface ResultPartitionWriter

All Known Implementing Classes:

ResultPartition

public interface ResultPartitionWriter

A buffer-oriented runtime result writer API for producing results.

Method Summary

Modifier and Type	Method and Description
void	addBufferConsumer(BufferConsumer bufferConsumer, int subpartitionIndex) Adds the bufferConsumer to the subpartition with the given index.
void	flush(int subpartitionIndex) Manually trigger consumption from enqueued BufferConsumers in one specified subpartition.
void	flushAll() Manually trigger consumption from enqueued BufferConsumers in all subpartitions.
BufferProvider	getBufferProvider()
int	getNumberOfSubpartitions()
int	getNumTargetKeyGroups()
ResultPartitionID	getPartitionId()

Method Detail

getBufferProvider

BufferProvider getBufferProvider()

getPartitionId

ResultPartitionID getPartitionId()

getNumberOfSubpartitions

int getNumberOfSubpartitions()

getNumTargetKeyGroups

int getNumTargetKeyGroups()

addBufferConsumer

void addBufferConsumer(BufferConsumer bufferConsumer,
                       int subpartitionIndex)
                throws IOException

Adds the bufferConsumer to the subpartition with the given index.

For PIPELINED ResultPartitionTypes, this will trigger the deployment of consuming tasks after the first buffer has been added.

This method takes the ownership of the passed bufferConsumer and thus is responsible for releasing it's resources.

To avoid problems with data re-ordering, before adding new BufferConsumer the previously added one the given subpartitionIndex must be marked as BufferConsumer.isFinished().

Throws:

IOException

flushAll

void flushAll()

Manually trigger consumption from enqueued BufferConsumers in all subpartitions.

flush

void flush(int subpartitionIndex)

Manually trigger consumption from enqueued BufferConsumers in one specified subpartition.