如何在将BigDecimal集合加载为Spark数据集时在架构中指定Spark小数位数和精度

import org.apache.spark.sql.{SparkSession, Encoders}
import java.math.{BigDecimal, MathContext, RoundingMode}

val spark = SparkSession.builder()
  .appName("BigDecimal Spark Dataset")
  .master("local")
  .getOrCreate()

val bigDecimalEncoder = Encoders.kryo[Double].map((bd: BigDecimal) => {
  bd.setScale(2, RoundingMode.HALF_UP).doubleValue()
})

val bigDecimalList = List(
  BigDecimal.valueOf(10.123),
  BigDecimal.valueOf(20.456),
  BigDecimal.valueOf(30.789)
)

val dataset = spark.createDataset(bigDecimalList)(bigDecimalEncoder)