Как записать постоянное значение в файл паркета, используя Scala? - loops

Question

Как записать постоянное значение в файл паркета, используя Scala? - loops

0

Я использую spark. Я хочу сохранить значение 2.484, которое повторяется 13849 раз в файле паркета вместо консоли.сохранить значения в файле паркета вместо консоли

implicit class Rep(n: Int) {
def times[A](f: => A): Seq[A] = { 1 to n map(_ => f) } 
}
val myHis= 13849.times { "2.4848911616270923"}

этот код, который повторяет значение 2.484. Как сохранить это в файле паркета?

Источник

apache-spark scala loops parquet

374
1
11 май 2020 2020-05-11 10:17:48
Salma Elzeheiry

1 ответ

Pedro Correia Luís · Answer 1 · 2020-05-11 10:17:49

import org.apache.spark.sql._


val myHis:Dataset[String] = ???

val path:String = ??? //the path you want

myHis.write.mode(SaveMode.Overwrite).parquet(path)

Попробуйте это