如何将JSON模式转换为Spark模式?

fivyi3re  于 2023-10-23  发布在  Apache
关注(0)|答案(1)|浏览(111)

我有一个JSON schema,我想转换为Spark模式。我认为来自Zalando的this library可以帮助,但它似乎不再维护,它不工作。
我还能做什么呢?如果你问我,我认为这是一个相当常见的用例,所以Spark不支持它感到惊讶。

vuktfyat

vuktfyat1#

在scala中,你只需要写这个

import org.apache.spark.sql.types.{DataType, StructType}
val jsonSchema = "get your json schema from a file or hardcode it here directly"
val schemaFromJson = DataType.fromJson(jsonSchema).asInstanceOf[StructType]

相关问题