diff options
Diffstat (limited to 'backend/index.js')
| -rw-r--r-- | backend/index.js | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/backend/index.js b/backend/index.js index 45869fb..9679a02 100644 --- a/backend/index.js +++ b/backend/index.js @@ -11,6 +11,7 @@ const R = require('ramda'), const loadFTimestamped = source.loadFTimestamped(config); const deriveStatistics = reduce.deriveStatistics(config.reduce); const aggregatePayloads = reduce.aggregatePayloads(config.reduce); +const cleanPayloads = reduce.cleanPayloads(config.reduce); const saveFPayloads = file.saveFPayloads(config.file); function main() { @@ -22,7 +23,7 @@ function main() { const futures = R.map(loadFTimestamped, laterMoments); Future.parallel(1, futures) - .map(R.compose(deriveStatistics, aggregatePayloads, R.unnest)) + .map(R.compose(deriveStatistics, aggregatePayloads, cleanPayloads, R.unnest)) .chain(saveFPayloads(config.file.reportPattern())) .fork(console.error, (d) => console.log(JSON.stringify(d, null, 2))); } |