我有一个JSON schema,我想转换为Spark模式。我认为来自Zalando的this library可以帮助,但它似乎不再维护,它不工作。我还能做什么呢?如果你问我,我认为这是一个相当常见的用例,所以Spark不支持它感到惊讶。
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]
1条答案
按热度按时间vuktfyat1#
在scala中,你只需要写这个