Building an end-to-end Analytics Pipeline with PyFlink