search

twitter / scalding

A Scala API for Cascading
http://twitter.com/scalding
Apache License 2.0
3.49k stars 703 forks source link

Add requireSingleValuePerKey #1828

Closed johnynek closed 6 years ago

johnynek commented 6 years ago

This has come up as a frequently useful function at Stripe for debugging.

In addition to debugging, the new optimizer can make use of this information and potentially reduce the cost of joins.

johnynek commented 6 years ago

@ianoc can you take a look?

ianoc commented 6 years ago

lgtm