[BEAM-7682] Combine.GroupedValues javadoc code snippet does not work

• Type: Bug
• Status: Resolved
• Priority: P3
• Resolution: Fixed
• Fix Version/s: 2.15.0
• Component/s: sdk-java-core
• Labels: Done documentation javadoc
• Assignee: Ismaël Mejía
• Reporter: Ismaël Mejía
• Created: 03/Jul/19 09:45
• Updated: 06/Oct/20 21:56
• Resolved: 04/Jul/19 09:42

Description

The snippet in the javadoc of GroupedValues says:

PCollection<KV<String, Integer>> pc = ...;
PCollection<KV<String, Iterable<Integer>>> groupedByKey = pc.apply( new GroupByKey<String, Integer>());
PCollection<KV<String, Integer>> sumByKey = groupedByKey.apply( Combine.<String, Integer>groupedValues( new Sum.SumIntegerFn()));

but should be:

PCollection<KV<String, Integer>> pc = ...;
PCollection<KV<String, Iterable<Integer>>> groupedByKey = pc.apply(GroupByKey.create());
PCollection<KV<String, Integer>> sumByKey = groupedByKey.apply(Combine.groupedValues(Sum.ofIntegers()));

Issue Links

• links to: GitHub Pull Request #8995