MapReduce工作机制

学习资料

• Hadoop深入浅出MapReduce详解

map

Channel
    .of( 1, 2, 3, 4, 5 )
    .map { it * it }
    .subscribe onNext: { println it }, onComplete: { println 'Done' }

1
4
9
16
25
Done

flatten

Channel
    .of( [1,[2,3]], 4, [5,[6]] )
    .flatten()
    .view()

1
2
3
4
5
6

reduce

Channel
    .of( 1, 2, 3, 4, 5 )
    .reduce { a, b -> println "a: $a b: $b"; return a+b }
    .view { "result = $it" }

a: 1 b: 2
a: 3 b: 3
a: 6 b: 4
a: 10 b: 5
result = 15