Scalding DSL が通常の Scala コードにどのように変換されるかを調べるのを手伝ってください。
https://github.com/twitter/scalding/wiki/Fields-based-API-Reference#sortBy
例えば:
val fasterBirds = birds.map('speed -> 'doubledSpeed) { speed : Int => speed * 2 }
質問:
map,
Scalding のreduce、groupBy,
sort、および `scanLeftに独自の関数を追加するには、どのような規則に従う必要がありますか?- Scalding は、`'inpFld -> 'outFld などのフィールドの式を Scala コードにどのように変換しますか?
- Scalding トランスレータが作成するデータ構造/関数は何ですか? Scalding のソース コードのどこでそれらを見つけることができますか?
ありがとう!