lomm28

import { createReadStream } from 'fs';
import { pipeline, PassThrough } from 'stream';
import parse from 'csv-parse';

const csvParser = parse({ columns: true });

const crimesDataFile = createReadStream('./data/london_crime_by_lsoa.csv');

class AbstractDataAggregator {
  constructor() {