sc = SparkContext(conf=conf).getOrCreate() sqlContext = SQLContext(sc) df = sqlContext.read.parquet("s3a://datalake/warehouse/platform/company_list/")