[FLINK-1034] Inconsistent naming of DataSet reduceGroup and GroupReduceFunction

• Type: Improvement
• Status: Closed
• Priority: Minor
• Resolution: Won't Fix
• Labels: breaking-api
• Assignee: Unassigned
• Reporter: Ufuk Celebi
• Created: 24/Jul/14 10:15
• Updated: 13/Apr/21 20:41
• Resolved: 29/Jul/14 14:09

Description

I don't know if it is on purpose or not, but I found it to be inconsistent and sometimes also confusing:

Why not

input.groupReduce(new GroupReduceFunction() {...})

instead of the current

input.reduceGroup(new GroupReduceFunction() {...})

I think it's the same line of thinking, which results in overriding a reduce method in GroupReduceFunction instead of a groupReduce method.

Is there a nice way to unify this?