SPARKorg.apache.spark.sql.Column的构造并且设置别名 想通过配置调用agg方法, 不知如何构造spark.sql.Column, 所以研究了下, 记录下: agg方法: def agg(expr: Column, exprs: Column*): DataFrame = { toDF((expr +: exprs).map { case typed: TypedColumn[_, ……继续阅读 » wangting 3年前 (2020-11-06) 462浏览 6个赞