python from pyspark.sql import SparkSession spark = SparkSession \ .builder \ .appName("PySpark Hive Integration") \ .enableHiveSupport() \ .getOrCreate() df = spark.sql("SELECT * FROM my_table") df.show() spark.stop()