[FLINK-5851] Renaming AsyncCollector into ResultPromise/ResultFuture

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.2.0, 1.3.0
• Fix Version/s: 1.4.0
• Component/s: API / DataStream
• Labels: api-breaking

Release Note

The API of AsyncFunction is changed. The type of object handed to {{asyncInvoke()}} is now {{ResultFuture}} instead of {{AsyncCollector}}. In order to complete the future with the result one has to call {{ResultFuture#complete}} or {{ResultFuture#completeExceptionally}} in case of an exceptional completion.

• Assignee: zhangminglei
• Reporter: Till Rohrmann
• Created: 20/Feb/17 15:00
• Updated: 08/Nov/17 14:44
• Resolved: 08/Nov/17 14:44

Description

Currently, the async I/O API gives an AsyncCollector to an AsyncFunction implementation. The name does not really reflect what the AsyncCollector does since it does not collect but is actually a one time completable future. Therefore, I propose to rename the AsyncCollector into ResultPromise or ResultFuture. This is API changing.

Issue Links

• links to: GitHub Pull Request #4243