Spark数据框架中Decimal列的模式验证方法不正确。

通过使用StructType和DecimalType的组合，创建正确的Decimal列模式。

示例代码：

import org.apache.spark.sql.types.{DecimalType, StringType, StructField, StructType} import org.apache.spark.sql.functions.col

// 创建Spark数据框架 val data = Seq((1, "one", BigDecimal(10.123)), (2, "two", BigDecimal(20.456)), (3, "three", BigDecimal(30.789)))

// 定义数据框架的模式 val schema = StructType(Seq( StructField("id", StringType, true), StructField("name", StringType, true), StructField("amount", DecimalType(10,3), true) ))

// 使用定义好的模式创建数据框架 val df = spark.createDataFrame(data).toDF(schema.fieldNames: _*)

// 验证Decimal列的模式是否正确 df.printSchema()

// 选择Decimal列并打印数据 df.select(col("amount")).show()