import sparkSession.implicits._
val innerDataFrame = 某个DataFrame
val summuryAmountDiffDataFrame = innerDataFrame.filter($"summary_amount" =!= $"summary_amount2").filter($"summary_count" === $"summary_count2")
// 或者
val summuryAmountDiffDataFrame2 = innerDataFrame.where("summary_amount != summary_amount2 AND summary_count == summary_count2")
注：
1、summary_amount、summary_amount2、summary_count、summary_count2是innerDataFrame的列；
2、一定要导入 import sparkSession.implicits._
版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由极客之家整理，本文链接：https://www.bmabk.com/index.php/post/17232.html
