[FLINK-7699] Define the BufferListener interface to replace EventListener in BufferProvider

• Type: Sub-task
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.4.0
• Assignee: Zhijiang
• Reporter: Zhijiang
• Created: 27/Sep/17 10:17
• Updated: 28/Feb/19 13:21
• Resolved: 10/Oct/17 14:54

Description

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.

Issue Links

• links to: GitHub Pull Request #4735