%scala val df = Seq((2012, 8, "Batman", 9.8), (2012, 8, "Hero", 8.7), (2012, 7, "Robot", 5.5), (2011, 7, "Git", 2.0)) .toDF("year", "month", "title", "rating") df.write.mode("overwrite").partitionBy("year", "month").format("avro").save("/tmp/test_dataset") display(dbutils.fs.ls("/tmp/test_dataset"))
Last refresh: Never