WIP: ingestion pipeline, spouts implemented