Building stream processing pipelines with Dataflow