写成spark-sql

Spark SQL是Apache Spark中的一个模块，用于处理结构化数据。它提供了一种编程接口，可以使用SQL语句或DataFrame API来查询和分析数据。

在编写Spark SQL时，你可以按照以下步骤进行：

1. 导入必要的库和类：

   import org.apache.spark.sql.SparkSession

2. 创建SparkSession对象：

   val spark = SparkSession.builder()
                           .appName("Spark SQL Example")
                           .config("spark.some.config.option", "some-value")
                           .getOrCreate()

3. 加载数据：

   val data = spark.read.format("csv")
                       .option("header", "true")
                       .load("path/to/data.csv")

4. 注册表：

   data.createOrReplaceTempView("myTable")

5. 执行SQL查询：

   val result = spark.sql("SELECT * FROM myTable WHERE age > 25")

6. 显示结果：

   result.show()

以上是一个简单的Spark SQL示例，你可以根据具体需求进行更复杂的操作。如果你想了解更多关于Spark SQL的内容，可以参考官方文档或其他相关资源。