from pyspark.sql import SparkSession from pyspark.sql import functions as F spark = ( SparkSession.builder.appName("dataframe-explain-plan") .config("spark.ui.enabled", "false") .config("spark.sql.adaptive.enabled", "true") .getOrCreate() ) spark.sparkContext.setLogLevel("ERROR")