我试过了
val temp = Seq[ProcessAction]() // ProcessAction is declared in Thrift
val toDF = temp.toDF()
scala.ScalaReflectionException:无是一个术语
如果我使用case类对象而不是ProcessAction
,我可以获得DataFrame...
有什么方法可以消除这个错误吗??
发布于 2018-08-15 07:28:28
拼图文件可以识别Thrift编码的对象,因此您可以使用ThriftParquetWriter加载拼图文件,然后使用Spark SQL或其他工具将这些对象放入DataFrame。
https://stackoverflow.com/questions/51835556
复制相似问题