WIP: ingestion pipeline, add perf_pipeline performance test (doesn't work at this moment).