import pyspark from pyspark.sql import SparkSession spark = SparkSession.builder.master("local[1]") \ .appName("SparkByExamples.com")\ .getOrCreate() df = spark.read.csv(r"C:\Users\ankus\PycharmProjects\DecHadoop\Resources\region_country.csv") print(df.is_cached) df.cache() print(df.is_cached) df.persist(pyspark.storagelevel.StorageLevel.MEMORY_AND_DISK) print(df.is_cached) df.show()