spark求每个城市的平均温度

您好！对于您的问题，可以使用Spark来求每个城市的平均温度。假设您有一个包含城市和温度的数据集，可以按照以下步骤进行处理：

1. 创建一个Spark应用程序，并导入必要的类和库。
2. 加载数据集到Spark中，可以使用`spark.read.csv()`方法或其他适当的方法。
3. 对数据进行预处理，确保温度列是数值型数据。
4. 使用`groupBy()`方法按照城市进行分组。
5. 使用`agg()`方法计算每个城市的平均温度，可以使用`avg()`函数。
6. 可以选择将结果保存到文件或输出到控制台。

以下是一个示例代码片段，仅供参考：

from pyspark.sql import SparkSession
from pyspark.sql.functions import avg

# 创建SparkSession
spark = SparkSession.builder.appName("AverageTemperature").getOrCreate()

# 加载数据集
data = spark.read.csv("data.csv", header=True, inferSchema=True)

# 预处理数据
data = data.withColumn("temperature", data["temperature"].cast("double"))

# 按照城市分组并计算平均温度
avg_temperature = data.groupBy("city").agg(avg("temperature").alias("avg_temperature"))

# 输出结果
avg_temperature.show()

# 停止SparkSession
spark.stop()

请注意，上述代码仅为示例，具体实现可能因您的数据集和需求而有所不同。希望以上信息对您有所帮助！如有任何问题，请随时提问。