使用spark实现求数据库中的各个专业的平均工资

好的，针对您的问题，我可以给出大致的实现思路：

1. 从数据库中读取数据，可以使用Spark SQL来实现。

2. 对数据按照专业进行分组，使用groupBy操作。

3. 对每个专业的工资求平均值，使用agg操作，并对结果进行重命名，以便后续处理。

4. 对结果进行排序，可以使用orderBy操作。最后将结果保存到文件或者数据库中。

下面是一份简单的Spark代码实现，供您参考：

import org.apache.spark.sql.SparkSession

object AverageSalary {
  def main(args: Array[String]): Unit = {
    val spark = SparkSession.builder()
      .appName("AverageSalary")
      .master("local[*]")
      .getOrCreate()

    val url = "jdbc:mysql://your_database_url:3306/your_database_name"
    val table = "your_table_name"
    val user = "your_username"
    val password = "your_password"

    val df = spark.read.format("jdbc")
      .option("url", url)
      .option("dbtable", table)
      .option("user", user)
      .option("password", password)
      .load()

    val result = df.groupBy("专业")
      .agg(avg("工资").alias("平均工资"))
      .orderBy("平均工资")

    result.show()

    spark.stop()
  }
}

需要注意的是，上述代码中的数据库连接信息、表名、字段名等需要根据实际情况进行修改。另外，需要在项目中引入对应的MySQL JDBC驱动。

希望以上内容对您有所帮助！