Wukong.dataflow(:mapper)  { identity }
Wukong.dataflow(:reducer) { identity }