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

Class ResultPartitionManager

java.lang.Object

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

All Implemented Interfaces:

ResultPartitionProvider

public class ResultPartitionManager
extends Object
implements ResultPartitionProvider

The result partition manager keeps track of all currently produced/consumed partitions of a task manager.

Constructor Summary

Constructors

Constructor	Description
ResultPartitionManager()

Method Summary

Modifier and Type	Method	Description
ResultSubpartitionView	createSubpartitionView(ResultPartitionID partitionId, int subpartitionIndex, BufferAvailabilityListener availabilityListener)	Returns the requested intermediate result partition input view.
Collection<ResultPartitionID>	getUnreleasedPartitions()
void	registerResultPartition(ResultPartition partition)
void	releasePartition(ResultPartitionID partitionId, Throwable cause)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

ResultPartitionManager

public ResultPartitionManager()

Method Detail

registerResultPartition

public void registerResultPartition(ResultPartition partition)

createSubpartitionView

public ResultSubpartitionView createSubpartitionView(ResultPartitionID partitionId,
                                                     int subpartitionIndex,
                                                     BufferAvailabilityListener availabilityListener)
                                              throws IOException

Description copied from interface: ResultPartitionProvider

Returns the requested intermediate result partition input view.

Specified by:

createSubpartitionView in interface ResultPartitionProvider

Throws:

IOException

releasePartition

public void releasePartition(ResultPartitionID partitionId,
                             Throwable cause)

shutdown

public void shutdown()

getUnreleasedPartitions

public Collection<ResultPartitionID> getUnreleasedPartitions()