结果组上的Spark Scala过滤器
我试图在一组结果上过滤数据框。
样本数据框代码-
scala> val df = sc.parallelize(Seq(
(1, 1, "m10", "t22"),
(1, 2, "m10", "t22"),
(1, 3, "m11", "t22"),
(1, 4, "m11", "t22"),
(1, 5, "m10", "t22"),
(1, 6, "m10", "t22"),
(1, 7, "m10", "t22"),...