Geo*_*ler 5 scala projection case-class apache-spark enumeratum
我有一个 Enumeratum 枚举,需要将其加载到 spark 数据框中。显然,这是由于缺少编码器而失败的。
import enumeratum._
sealed trait Foo extends EnumEntry
object Foo extends Enum[Foo] {
val values = findValues
case object Baz extends Foo
case object Bar extends Foo
}
case class FooBar(a:Int, lotOfOthterFields:String, xxxx:Seq[Foo])
Seq(FooBar(1, "one", Foo.Baz), FooBar(2, "two", Foo.Bar)).toDF
Run Code Online (Sandbox Code Playgroud)
失败No Encoder found for type Foo。我如何将案例类(没有样板)投影到:
Foo.Baz.entryName(但没有定义类似的类)将其转换为字符串Seq(FooBar(1, "one", Foo.Baz), FooBar(2, "two", Foo.Bar)).map(allValluesButxxxx, xxxx.entryName)| 归档时间: |
|
| 查看次数: |
184 次 |
| 最近记录: |