Как записать постоянное значение в файл паркета, используя Scala? - PullRequest
0 голосов
/ 17 октября 2019

Я использую искру. Я хочу сохранить значение 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. Как сохранить его в файл паркета?

1 Ответ

0 голосов
/ 17 октября 2019
import org.apache.spark.sql._


val myHis:Dataset[String] = ???

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

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

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

...