Modified data pipeline to use Node streams for I/O optimization