[FLINK-5630] Followups to AggregationFunction

• Type: Improvement
• Status: Closed
• Priority: Major
• Resolution: Fixed
• Affects Version/s: 1.3.0
• Fix Version/s: 1.3.0
• Component/s: API / DataStream
• Assignee: Stephan Ewen
• Reporter: Stephan Ewen
• Created: 24/Jan/17 19:11
• Updated: 28/Feb/19 11:14
• Resolved: 25/Jan/17 19:59

Description

Various followup issues to the aggregation function, like

• Allowing different input/output types for the cases where an additional window apply function is specified

• Adding the aggregate() methods to the Scala API

• Adding the window translation tests

Issue Links

• links to: GitHub Pull Request #3207