请帮助了解 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 源代码中哪里可以找到它们?
谢谢!