1 |
|
2 |
|
3 | var sc = require('skale-engine').context();
|
4 |
|
5 | function reducer(a, b) {a.push(b); return a;}
|
6 | function combiner(a, b) {return a.concat(b);}
|
7 |
|
8 | var a = sc.parallelize([1, 2, 3, 4], 2).persist();
|
9 |
|
10 | a.aggregate(reducer, combiner, [], function(err, res) {
|
11 | console.log('First Time !');
|
12 | console.log(res);
|
13 |
|
14 | a.aggregate(reducer, combiner, [], function(err, res) {
|
15 | console.log('\nSecond Time !');
|
16 | console.log(res);
|
17 | sc.end();
|
18 | });
|
19 | });
|