https://dataengineerblog.com/sql-to-pyspark-query-converstion/