[ https://issues.apache.org/jira/browse/BEAM-1804?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Xu Mingmin closed BEAM-1804. ---------------------------- Resolution: Not A Problem Fix Version/s: Not applicable > expose values in CoGbkResult as Iterable<?> > ------------------------------------------- > > Key: BEAM-1804 > URL: https://issues.apache.org/jira/browse/BEAM-1804 > Project: Beam > Issue Type: Improvement > Components: sdk-java-core > Reporter: Xu Mingmin > Assignee: Xu Mingmin > Fix For: Not applicable > > > The joined result of {{CoGroupByKey}} is stored in {{List<Iterable<?>> > valueMap}} of {{CoGbkResult}}. > Now it's exposed as a singleton value with methods {{<V> V > getOnly(TupleTag<V> tag)}}. This function throws exception if there're more > than one records for given tag. > Would like to add a new method {{Iterator<V> getIterator(TupleTag<V> tag)}}, > to cover the case with multiple-row. -- This message was sent by Atlassian JIRA (v6.3.15#6346)