filter的问题

来源:6-7 Spark SQL内置函数实战

慕九州3016327

2020-09-13

老师你好,
userDF.groupBy(“day”).agg(countDistinct(“userId”).as(“uv”)).filter(“day==2016-10-01”)
我想以userDF.groupBy(“day”).agg(countDistinct(“userId”).as(“uv”))输出的结果再次过滤,把day=2016-10-01的过滤出来,怎么写都不行,这里的filter()里面的格式应该怎么写呢老师。

写回答

1回答

Michael_PK

2020-09-13

报什么错

0
5
慕九州3016327
回复
Michael_PK
userDF.groupBy("day").agg(countDistinct("userId").as("uv")).filter($"day".equalTo("2016-10-01")).show()可以了
2020-09-13
共5条回复

SparkSQL入门 整合Kudu实现广告业务数据分析

大数据工程师干货课程 带你从入门到实战掌握SparkSQL

535 学习 · 192 问题

查看课程