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 boolean	notifyPriorityEvent(BufferConsumer eventBufferConsumer) Allows the listener to react to a priority event before it is added to the outgoing buffer queue.

Method Detail

notifyDataAvailable

void notifyDataAvailable()

Called whenever there might be new data available.

notifyPriorityEvent

default boolean notifyPriorityEvent(BufferConsumer eventBufferConsumer)
                             throws IOException

Allows the listener to react to a priority event before it is added to the outgoing buffer queue.

Returns:

true if the event has been fully processed and should not be added to the buffer queue.

Throws:

IOException