[FLINK-11604] Extend the necessary methods in ResultPartitionWriter interface

• Type: Sub-task
• Status: Closed
• Priority: Minor
• Resolution: Duplicate
• Component/s: Runtime / Network
• Labels: pull-request-available
• Assignee: Zhijiang
• Reporter: Zhijiang
• Created: 14/Feb/19 03:43
• Updated: 04/Jun/19 13:40
• Resolved: 04/Jun/19 13:40

Description

This is a preparation work for future creating ResultPartitionWriter via proposed ShuffleService.

Currently there exists only one ResultPartition implementation for ResultPartitionWriter interface, so the specific ResultPartition instance is easily referenced in many other classes such as Task, NetworkEnvironment, etc. Even some private methods in ResultPartition would be called directly in these reference classes.

Considering ShuffleService might create multiple different ResultPartitionWriter implementations future, then all the other classes should only reference with the interface and call the common methods. Therefore we extend the related methods in ResultPartitionWriter interface in order to cover existing logics in ResultPartition.

Issue Links

• links to: GitHub Pull Request #7704