DataFrame 操作之 if 判断

spark DataFrame 的内容也可以用filter筛选，if用法;

spark 版本：2.1.0         scala：2.11

可以根据不同逻辑返回需要的数据，示例如下：

loadData.printSchema()
val mid1 = loadData.withColumn("mont", loadData("sum")+1)
  .dropDuplicates("id").selectExpr("*","if(id=1,'张三','李四') as name")
val mid2 = mid1.withColumn("payend",mid1("sum")+mid1("mont"))
mid2.show(false)

输出结果：