for i in range(DATA_SIZE // MEGABYTE):
    stream_writer.write_batch(batch)