相关疑难解决方法(0)

从案例类生成Spark StructType/Schema

如果我想创建一个StructType(即a DataFrame.schema)a case class,是否有办法在不创建的情况下创建DataFrame?我可以轻松地做到:

case class TestCase(id: Long)
val schema = Seq[TestCase]().toDF.schema
Run Code Online (Sandbox Code Playgroud)

但实际创建一个DataFrame我想要的只是模式似乎有点过分.

(如果你很好奇,问题背后的原因是我正在定义一个UserDefinedAggregateFunction,并且这样做会覆盖一些返回的方法,StructTypes并使用case类.)

apache-spark apache-spark-sql

47
推荐指数
4
解决办法
2万
查看次数

标签 统计

apache-spark ×1

apache-spark-sql ×1