Interface BufferAvailabilityListener
-
- All Known Implementing Classes:
LocalInputChannel
,UnionResultSubpartitionView
public interface BufferAvailabilityListener
Listener interface implemented by consumers ofResultSubpartitionView
that want to be notified of availability of further buffers.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Default Methods Modifier and Type Method Description void
notifyDataAvailable(ResultSubpartitionView view)
Called whenever there might be new data available.default void
notifyPriorityEvent(int prioritySequenceNumber)
Called when the first priority event is added to the head of the buffer queue.
-
-
-
Method Detail
-
notifyDataAvailable
void notifyDataAvailable(ResultSubpartitionView view)
Called whenever there might be new data available.- Parameters:
view
- theResultSubpartitionView
containing available data.
-
notifyPriorityEvent
default void notifyPriorityEvent(int prioritySequenceNumber)
Called when the first priority event is added to the head of the buffer queue.- Parameters:
prioritySequenceNumber
- the sequence number that identifies the priority buffer.
-
-