Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- ratingsCounts
- .apply("FormatResults", MapElements.into(TypeDescriptors.strings())
- .via((KV<String, Long> ratingsCount) -> ratingsCount.getKey() + " " + ratingsCount.getValue()))
- .apply(TextIO.write().to("./ratings_results").withSuffix(".csv"));
Add Comment
Please, Sign In to add comment
