Data streaming and processing pipelines