我正在从Hive表中阅读数据，然后尝试使用从其他列派生的额外列来丰富它。但Spark改变了我的模式并按名称排序所有列时遇到了一些问题。
在调用withColumn（）并使用我丰富的类对它进行编码之后，模式是正确的，但是每当我调用map（）时，模式就会发生变化，列的顺序就错了。如何告诉Spark保持列的原始顺序？

session.table("myTable")
    .as(Encoders.bean(Base.class))
    .withColumn("enrichedColumn", lit(""))
    .as(Encoders.bean(Enriched.class))
    .map(enriched -> enriched.enrich(), Encoders.bean(Enriched.class))
    .printSchema();

字符串