WIP ingestion pipeline - better parallelism in spouts