sparksql中构建和创表代码

在SparkSQL中，可以使用CREATE TABLE语句来创建表。以下是一个示例代码：

import org.apache.spark.sql.SparkSession

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

    // 读取数据源
    val df = spark.read
      .format("csv")
      .option("header", "true")
      .load("data.csv")

    // 创建表
    df.createOrReplaceTempView("myTable")

    // 执行SQL查询
    val result = spark.sql("SELECT * FROM myTable")

    // 显示结果
    result.show()

    // 停止SparkSession
    spark.stop()
  }
}

在上面的示例中，首先创建了一个SparkSession对象，然后使用spark.read方法从CSV文件加载数据源。接下来，使用createOrReplaceTempView方法将DataFrame注册为一个临时表。然后，使用spark.sql方法执行SQL查询，并使用show方法显示结果。最后，使用spark.stop方法停止SparkSession。

请注意，上述代码中的data.csv是一个示例数据源，你需要将其替换为你自己的数据源路径。另外，你还可以根据你的需求更改表名、查询语句等