Using Apache Hudi snapshot queries with PySpark

Problem statement: