Como você pode gravar em várias saídas dependentes da chave usando Scalding (/ em cascata) em um único trabalho de redução de mapa. Eu poderia, é claro, usar.filter para todas as chaves possíveis, mas esse é um truque horrível, que acionará muitos trabalhos.