Помогите, пожалуйста, разобраться, как Scalding DSL транслируется в обычный код Scala.
https://github.com/twitter/scalding/wiki/Fields-based-API-Reference#sortBy
Например:
val fasterBirds = birds.map('speed -> 'doubledSpeed) { speed : Int => speed * 2 }
Вопросы:
- Каким соглашениям я должен следовать, чтобы добавить свои собственные функции в Scalding
map,
reduce,groupBy,
sort и `scanLeft? - Как Scalding переводит выражения в таких полях, как `'inpFld -> 'outFld, в код Scala?
- Какие структуры данных/функции создает транслятор Scalding? Где их найти в исходниках Scalding?
Спасибо!