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

Interface BufferAvailabilityListener

All Known Implementing Classes:

LocalInputChannel

public interface BufferAvailabilityListener

Listener interface implemented by consumers of ResultSubpartitionView that want to be notified of availability of further buffers.

Method Summary

Modifier and Type	Method and Description
void	notifyDataAvailable() 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()

Called whenever there might be new data available.

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.