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

Interface ResultPartitionProvider

All Known Implementing Classes:

ResultPartitionManager

public interface ResultPartitionProvider

Interface for creating result partitions.

Method Summary

Modifier and Type	Method	Description
ResultSubpartitionView	createSubpartitionView(ResultPartitionID partitionId, int index, BufferAvailabilityListener availabilityListener)	Returns the requested intermediate result partition input view.

Method Detail

createSubpartitionView

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

Returns the requested intermediate result partition input view.

Throws:

IOException