1 |
|
2 |
|
3 | var sc = require('skale-engine').context();
|
4 |
|
5 | function by2(a, args) {return a * 2 * args.bias;}
|
6 | function sum(a, b) {return a + b;}
|
7 |
|
8 | sc.parallelize([1, 2, 3, 4])
|
9 | .map(by2, {bias: 2})
|
10 | .reduce(sum, 0, function(err, res) {
|
11 | console.log(res);
|
12 | console.assert(res == 40);
|
13 | sc.end();
|
14 | });
|