public interface ResultSubpartitionView
ResultSubpartition
instance.Modifier and Type | Method and Description |
---|---|
Throwable |
getFailureCause() |
ResultSubpartition.BufferAndBacklog |
getNextBuffer()
Returns the next
Buffer instance of this queue iterator. |
boolean |
isAvailable(int numCreditsAvailable) |
boolean |
isReleased() |
void |
notifyDataAvailable() |
default void |
notifyPriorityEvent(int priorityBufferNumber) |
void |
releaseAllResources() |
void |
resumeConsumption() |
int |
unsynchronizedGetNumberOfQueuedBuffers() |
@Nullable ResultSubpartition.BufferAndBacklog getNextBuffer() throws IOException
Buffer
instance of this queue iterator.
If there is currently no instance available, it will return null
. This might
happen for example when a pipelined queue producer is slower than the consumer or a spilled
queue needs to read in more data.
Important: The consumer has to make sure that each buffer instance will
eventually be recycled with Buffer.recycleBuffer()
after it has been consumed.
IOException
void notifyDataAvailable()
default void notifyPriorityEvent(int priorityBufferNumber)
void releaseAllResources() throws IOException
IOException
boolean isReleased()
void resumeConsumption()
Throwable getFailureCause()
boolean isAvailable(int numCreditsAvailable)
int unsynchronizedGetNumberOfQueuedBuffers()
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.