Я использую искру. Я хочу сохранить значение 2.484, которое повторяется 13849 раз в файле паркета вместо консоли. сохранить значения в файле паркета вместо консоли
implicit class Rep(n: Int) { def times[A](f: => A): Seq[A] = { 1 to n map(_ => f) } } val myHis= 13849.times { println("2.4848911616270923")}
этокод, который повторяет значение 2.484. Как сохранить его в файл паркета?
import org.apache.spark.sql._ val myHis:Dataset[String] = ??? val path:String = ??? //the path you want myHis.write.mode(SaveMode.Overwrite).parquet(path)
Попробуйте это