Skip to content

Instantly share code, notes, and snippets.

@imrenagi

imrenagi/flatten.java

Created January 8, 2019 23:51
Show Gist options
  • Save imrenagi/2e909e5d37295a9c22ad8389730aedb9 to your computer and use it in GitHub Desktop.
Save imrenagi/2e909e5d37295a9c22ad8389730aedb9 to your computer and use it in GitHub Desktop.
Download ZIP
Raw
flatten.java
//merge the two PCollections
PCollectionList<String> collectionList = PCollectionList.of(aCollection).and(bCollection);
//flatten
PCollection<String> mergedCollectionWithFlatten = collectionList.apply(Flatten.<String>pCollections());
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment