Помогите, пожалуйста, разобраться, как Scalding DSL транслируется в обычный код Scala. https://github.com/twitter/scalding/wiki/Fields-based-API-Reference#sortBy Например: val fasterBirds = birds.map('speed -> 'doubledSpeed) { speed :...

Почему в Scala и таких фреймворках, как Spark и Scalding, есть и reduce , и foldLeft ? Так в чем же разница между reduce и fold ?

У меня есть приведенный ниже код example для некоторой предварительной обработки перед запуском задания sclading и некоторой последующей обработки. Поскольку эти предварительная и постпроцессная обработка вызывают некоторую базу данных mysql, я...