场景:
hive中事先创建好分区表test_table_name,然后通过spark streaming任务处理数据,将rdd转为dataframe后写hive。
具体出错代码
val result sparkSession.createDataFrame(rdd, schema)result.write.mode("append").format…
比较 BigDecimal提供了compareTo方法进行比较值的大小,返回值是int。 这是方法注释上面定义的返回值 :-1, 0, or 1 as this {code BigDecimal} is numerically less than, equal to, or greater than {code val}. 直接上代码吧,看看怎么做比较…