Я новый ученик для Pyspark.В моем проекте есть требование прочитать файл JSON со схемой, и мне нужно преобразовать его в файл CSV.
Может кто-нибудь помочь мне выполнить этот запрос с помощью PYspark.
Вы можете загрузить JSON и написать CSV с помощью SparkSession.
spark = SparkSession.builder.master("local").appName("ETL").getOrCreate() spark.read.json(path-to-txt) spark.write.csv(path-to-csv)