我试图在不同的列上进行聚合,在相同的列上进行不同的聚合,也就是在下面的例子中,我正在计算stake_amount上的和,并指望日志胜利。但是,我需要计算stake_amount上的均值,并在这个code.following中将其重命名为平均值,只要我在stake_amount上执行one聚合,但当我试图添加另一个聚合为 mean 时,它只显示了平均值,而不是sum,请帮助……下面是一个聚合<
通常,一个组中的所有行都被传递给一个聚合函数。我想使用一个条件来筛选行,以便只将组中的一些行传递给聚合函数。使用可以进行这样的操作。我想用Spark SQL DataFrame (Spark 2.0.0)做同样的事情。where("B").less(10), // there is no such method as `where` :(
max("C").where("C&qu