| 1 |
|
| 2 |
|
| 3 | var sc = require('skale-engine').context();
|
| 4 |
|
| 5 | var file = process.argv[2] || '/etc/hosts';
|
| 6 |
|
| 7 | sc.textFile(file)
|
| 8 | .flatMap(line => line.split(' '))
|
| 9 | .map(word => [word, 1])
|
| 10 | .reduceByKey((a, b) => a + b, 0)
|
| 11 | .count()
|
| 12 | .then(function (res) {
|
| 13 | console.log(res);
|
| 14 | sc.end();
|
| 15 | });
|