Build unified batch and streaming pipelines on popular ML frameworks