Building a data pipeline from Batch and Streaming data