zhijiang created FLINK-7699:
-------------------------------

             Summary: Define the BufferListener interface to replace 
EventlListener in BufferProvider
                 Key: FLINK-7699
                 URL: https://issues.apache.org/jira/browse/FLINK-7699
             Project: Flink
          Issue Type: Sub-task
          Components: Core
            Reporter: zhijiang
            Assignee: zhijiang
             Fix For: 1.4.0


Currently the {{EventListener}} is used in {{BufferProvider}} to be notified of 
buffer available or destroyed pool. 

To be semantic clearly, we define a new {{BufferListener}} interface which can 
opt for a one-time only notification or to be notified repeatedly. And we can 
also notify the pool destroyed via explicitly method {{notifyBufferDestroyed}}.

The {{RemoteInputChannel}} will implement the {{BufferListener}} interface to 
wait for floating buffers from {{BufferProvider}}.



--
This message was sent by Atlassian JIRA
(v6.4.14#64029)

Reply via email to