[FLINK-7837] AggregatingFunction does not work with immutable types

• Type: Bug
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 1.4.0
• Component/s: API / DataStream
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 13/Oct/17 15:40
• Updated: 21/Oct/17 07:36
• Resolved: 21/Oct/17 07:36

Description

Currently add() has this signature:

void add(IN value, ACC accumulator);

meaning that a value can only be added to an accumulator by modifying the accumulator. This should be extended to:

ACC add(IN value, ACC accumulator);

Issue Links

• is required by: FLINK-5968 Document WindowedStream.aggregate()