spark scala mysql 语法

标签：

https://spark.apache.org/docs/1.5.1/api/java/org/apache/spark/sql/DataFrame.html

people.filter("age > 30")
     .join(department, people("deptId") === department("id"))
     .groupBy(department("name"), "gender")
     .agg(avg(people("salary")), max(people("age")))

spark scala mysql 语法

标签：

原文地址：http://www.cnblogs.com/dataclimber/p/5166915.html