Как записать постоянное значение в файл паркета, используя 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. Как сохранить это в файле паркета?
Источник
- 374
- 1
- 11 май 2020 2020-05-11 10:17:48
- Salma Elzeheiry
1 ответ
0
import org.apache.spark.sql._
val myHis:Dataset[String] = ???
val path:String = ??? //the path you want
myHis.write.mode(SaveMode.Overwrite).parquet(path)
Попробуйте это
- 11 май 2020 2020-05-11 10:17:49
- Pedro Correia Luís