Implement parallel ingest