Моля, помогнете да разберете как 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?
Благодаря!