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 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.