写一段spark连接doris数据库的代码

以下是使用 Spark 连接到 Doris 数据库的代码示例：

import org.apache.spark.sql.{SparkSession, DataFrame}

val spark = SparkSession.builder()
  .appName("Doris Spark Connector")
  .master("local[*]")
  .getOrCreate()

val dorisHost = "doris_host"
val dorisPort = 9030
val dorisDatabase = "doris_database"
val dorisTable = "doris_table"
val dorisUser = "doris_user"
val dorisPassword = "doris_password"

// 创建 Doris 连接 URL
val url = s"jdbc:doris://$dorisHost:$dorisPort/$dorisDatabase"

// 定义连接属性
val connectionProperties = new java.util.Properties()
connectionProperties.setProperty("user", dorisUser)
connectionProperties.setProperty("password", dorisPassword)

// 读取 Doris 数据表并创建 Spark DataFrame
val dorisDF: DataFrame = spark.read
  .jdbc(url, dorisTable, connectionProperties)

此示例代码使用 `SparkSession` 创建了一个 Spark 应用程序，并使用 `jdbc` 方法从 Doris 数据库中读取数据表。在连接属性中设置用户名和密码，以便进行身份验证。最后，将返回的 `DataFrame` 分配给 `dorisDF` 变量，以便在 Spark 应用程序中使用。