public interface ResultPartitionProvider
Modifier and Type | Method and Description |
---|---|
ResultSubpartitionView |
createSubpartitionView(ResultPartitionID partitionId,
ResultSubpartitionIndexSet indexSet,
BufferAvailabilityListener availabilityListener)
Returns the requested intermediate result partition input view.
|
Optional<ResultSubpartitionView> |
createSubpartitionViewOrRegisterListener(ResultPartitionID partitionId,
ResultSubpartitionIndexSet indexSet,
BufferAvailabilityListener availabilityListener,
PartitionRequestListener partitionRequestListener)
If the upstream task's partition has been registered, returns the result subpartition input
view immediately, otherwise register the listener and return empty.
|
void |
releasePartitionRequestListener(PartitionRequestListener listener)
Release the given listener in this result partition provider.
|
ResultSubpartitionView createSubpartitionView(ResultPartitionID partitionId, ResultSubpartitionIndexSet indexSet, BufferAvailabilityListener availabilityListener) throws IOException
IOException
Optional<ResultSubpartitionView> createSubpartitionViewOrRegisterListener(ResultPartitionID partitionId, ResultSubpartitionIndexSet indexSet, BufferAvailabilityListener availabilityListener, PartitionRequestListener partitionRequestListener) throws IOException
partitionId
- the result partition idindexSet
- the index setavailabilityListener
- the buffer availability listenerpartitionRequestListener
- the partition request listenerIOException
- the thrown exceptionvoid releasePartitionRequestListener(PartitionRequestListener listener)
listener
- the given listenerCopyright © 2014–2024 The Apache Software Foundation. All rights reserved.