Xu Mingmin created BEAM-1804:
--------------------------------
Summary: 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
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)
