Xu Mingmin created BEAM-1805: -------------------------------- Summary: a new option `asInnerJoin` for CoGroupByKey Key: BEAM-1805 URL: https://issues.apache.org/jira/browse/BEAM-1805 Project: Beam Issue Type: Improvement Components: sdk-java-core Reporter: Xu Mingmin Assignee: Xu Mingmin
{{CoGroupByKey}} joins multiple PCollection<KV<K, V>>, act as full-outer join. Option {{asInnerJoin()}} restrict the output to convert to an inner-join behavior. -- This message was sent by Atlassian JIRA (v6.3.15#6346)