From c8d900349a2a518c5fee9610b6a903a2ff546e50 Mon Sep 17 00:00:00 2001 From: schneefux Date: Sat, 5 May 2018 23:31:56 +0200 Subject: cache many small periods on disk and aggregate them --- etl.js | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'etl.js') diff --git a/etl.js b/etl.js index bbb8205..7334b7d 100644 --- a/etl.js +++ b/etl.js @@ -157,7 +157,10 @@ function loadFPayloads(config) { Future.both, R.map(R.pipe( joinParticipantRosterMatchPayloadsToTelemetryPayloads, - R.map(R.omit(['_asset_id', '_participant_id', '_participant_ids', '_roster_id', '_roster_ids', '_match_id', 'Team'])), + R.map(R.pipe( + R.omit(['_asset_id', '_participant_id', '_participant_ids', '_roster_id', '_roster_ids', '_match_id', 'Team']), + R.set(R.lensProp('Count'), 1), + )), )), ), [ loadFParticipantRosterMatchPayloads, -- cgit v1.3.1