skale-engine/examples/reduceByKey.js

#!/usr/bin/env node

var sc = require('skale-engine').context();

var data = [['hello', 1], ['hello', 1], ['world', 1]];
var nPartitions = 2;

var init = 0;

function reducer(a, b) {return a + b;}

sc.parallelize(data, nPartitions)
  .reduceByKey(reducer, init)
  .collect(function(err, res) {
    console.log(res);
    console.assert(JSON.stringify(res) === JSON.stringify([['hello', 2], ['world', 1]]));   
    sc.end();
  });