[jira] [Created] (FLINK-7699) Define the BufferListener interface to replace EventlListener in BufferProvider

classic Classic list List threaded Threaded
1 message Options
Reply | Threaded
Open this post in threaded view
|

[jira] [Created] (FLINK-7699) Define the BufferListener interface to replace EventlListener in BufferProvider

Shang Yuanchun (Jira)
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)