如题,Spark2.x之SparkSql读取MySQL数据中Decimal类型如何读取?
我在读取MySQL数据时有个字段是Decimal字段,SparkSql,getAs[BigDecimal]出现报错,具体报错信息如下:
java.lang.ClassCastException: java.math.BigDecimal cannot be cast to scala.math.BigDecimal
sparksql代码如下
val filtered: Dataset[Row] = orders.filter(o => {
o.getAs[BigDecimal]("total_price") >= 8
})
filtered.show()
请问如果不采用sql语句的方式去cast,该怎么修改这个代码?