1BRC JavaScript / Node.js

calculate-average-await.js

import {createReadStream} from 'node:fs';
import * as readline from 'node:readline/promises';

const start_time = process.hrtime();
const data = new Map();

const filename = process.argv[2] || '../../../data/weather-data-1M.csv';
console.log('filename: %s\n----', filename);

const fileStream = createReadStream(filename);
const rl = readline.createInterface({
    input: fileStream,
    crlfDelay: Infinity,
});

for await (const line of rl) {
    let [name, temp] = line.split(';');
    temp = parseFloat(temp);

    const next = {count: 1, sum: temp, min: temp, max: temp};
    const a = data.get(name);
    if (!!a) {
        next.count = 1 + a.count;
        next.sum += a.sum;
        next.min = Math.min(temp, a.min);
        next.max = Math.max(temp, a.max);
    }
    data.set(name, next);
}

const sortable = [...data.entries()];
sortable.sort((a, b) => a[0].localeCompare(b[0]))
sortable.forEach(([name, aggr]) => {
    console.log('%s: %f C, %f/%f (%d)', name,
        (aggr.sum / aggr.count).toFixed(1),
        (aggr.min).toFixed(1),
        (aggr.max).toFixed(1),
        aggr.count)
})
console.log('----')

const [secs, nano] = process.hrtime(start_time);
const elapsed = (secs + nano * 1E-9).toFixed(3)
process.stderr.write('[js await] elapsed ' + elapsed + ' seconds, ' + filename + '\n')

calculate-average-events.js

import {createReadStream} from 'node:fs';
import * as readline from 'node:readline/promises';

const start_time = process.hrtime();
const data = new Map();

const filename = process.argv[2] || '../../../data/weather-data-1M.csv';
console.log('filename: %s\n----', filename);

const fileStream = createReadStream(filename);
const rl = readline.createInterface({
    input: fileStream,
    crlfDelay: Infinity,
});

rl.on('line', line => {
    let [name, temp] = line.split(';');
    temp = parseFloat(temp);

    const next = {count: 1, sum: temp, min: temp, max: temp};
    const a = data.get(name);
    if (!!a) {
        next.count = 1 + a.count;
        next.sum += a.sum;
        next.min = Math.min(temp, a.min);
        next.max = Math.max(temp, a.max);
    }
    data.set(name, next);
});

rl.on('close', () => {
    let sortable = [...data.entries()];
    sortable.sort((a, b) => a[0].localeCompare(b[0]))
    sortable.forEach(([name, aggr]) => {
        console.log('%s: %f C, %f/%f (%d)', name,
            (aggr.sum / aggr.count).toFixed(1),
            (aggr.min).toFixed(1),
            (aggr.max).toFixed(1),
            aggr.count)
    })
    console.log('----')

    const [secs, nano] = process.hrtime(start_time);
    const elapsed = (secs + nano * 1E-9).toFixed(3)
    process.stderr.write('[js await] elapsed ' + elapsed + ' seconds, ' + filename + '\n')
});

rl.on('error', err => {
    console.error('ooops:', err);
});