[FLINK-10662] Refactor the ChannelSelector interface for single selected channel

• Type: Sub-task
• Status: Closed
• Priority: Minor
• Resolution: Fixed
• Affects Version/s: 1.5.4, 1.6.1
• Fix Version/s: 1.8.0
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Zhijiang
• Reporter: Zhijiang
• Created: 24/Oct/18 08:27
• Updated: 02/Oct/19 17:44
• Resolved: 30/Jan/19 13:22

Description

In the discussion of broadcast improvement, pnowojski pointed out the issue of improving the current channel selector.

 

In ChannelSelector#selectChannels, it would return an array for selected channels. But considering specific implementations, only BroadcastPartitioner would select all the channels, and other implementations will select one channel. So we can simple this interface to return single channel index for benefiting performance, and specialize the BroadcastPartitioner in a more efficient way.

Issue Links

• links to: GitHub Pull Request #7199