[FLINK-9152] Harmonize BroadcastProcessFunction Context names

• Type: Improvement
• Status: Closed
• Priority: Blocker
• Resolution: Fixed
• Affects Version/s: 1.5.0
• Fix Version/s: 1.5.0
• Component/s: API / DataStream
• Assignee: Aljoscha Krettek
• Reporter: Aljoscha Krettek
• Created: 09/Apr/18 23:08
• Updated: 12/Apr/18 22:40
• Resolved: 12/Apr/18 22:40

Description

Currently, the Context on KeyedBroadcastProcessFunction is called KeyedContext, which is different from the name of the context on BroadcastProcessFunction. This leads to the strange combination of

public abstract void processBroadcastElement(final IN2 value, final KeyedContext ctx, final Collector<OUT> out) throws Exception;

i.e. you're processing a broadcast element but the context is called a "keyed" context.

Issue Links

• links to: GitHub Pull Request #5830