spark toDS() toDF()和import spark.implicits.

我就是400: 这代码其实可以不用if语句，太麻烦。完全可以写成下面的： md5(to_utf8( concat( coalesce( cast(id as VARCHAR) , '-' ), coalesce( cast(city_id as VARCHAR) , '-' ), coalesce( cast(user_id as VARCHAR) , '-' ), ... ) )) as record_key

qq_56411602: 大概看完了，写得好好，会再多刷几遍的

3.1415926: 运行时数据区，应该把元空间给加上

MAL_007: 比较基础，感觉一般，

码中无情搬运工: 你发的这个链接上面标明了转载 不过没给转载地址