public class BoundedBlockingSubpartitionDirectTransferReader extends Object implements ResultSubpartitionView
FileRegion
.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() |
void |
releaseAllResources() |
void |
resumeConsumption() |
String |
toString() |
int |
unsynchronizedGetNumberOfQueuedBuffers() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
notifyPriorityEvent
@Nullable public ResultSubpartition.BufferAndBacklog getNextBuffer() throws IOException
ResultSubpartitionView
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.
getNextBuffer
in interface ResultSubpartitionView
IOException
public boolean isAvailable(int numCreditsAvailable)
isAvailable
in interface ResultSubpartitionView
public void releaseAllResources() throws IOException
releaseAllResources
in interface ResultSubpartitionView
IOException
public boolean isReleased()
isReleased
in interface ResultSubpartitionView
public Throwable getFailureCause()
getFailureCause
in interface ResultSubpartitionView
public int unsynchronizedGetNumberOfQueuedBuffers()
unsynchronizedGetNumberOfQueuedBuffers
in interface ResultSubpartitionView
public void notifyDataAvailable()
notifyDataAvailable
in interface ResultSubpartitionView
public void resumeConsumption()
resumeConsumption
in interface ResultSubpartitionView
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.