如何使用Spark & Scala将数据写入CouchBase？

import org.apache.spark.sql.SparkSession
import com.couchbase.client.java.{Bucket, CouchbaseCluster}
import com.couchbase.spark._

object SparkCouchbaseExample {
  def main(args: Array[String]): Unit = {
    // 创建SparkSession对象
    val spark = SparkSession.builder()
      .appName("Spark Couchbase Example")
      .master("local")
      .config("spark.couchbase.nodes", "localhost") // Couchbase节点地址
      .config("spark.couchbase.bucket.default", "") // Couchbase桶名称
      .getOrCreate()

    // 读取数据源，例如从文件中读取数据
    val data = spark.read.textFile("path/to/data.txt")

    // 对数据进行处理和转换
    val transformedData = data.map(line => line.toUpperCase())

    // 创建Couchbase连接对象
    val cluster = CouchbaseCluster.create("localhost") // Couchbase节点地址
    val bucket = cluster.openBucket("") // Couchbase桶名称

    // 将数据写入Couchbase数据库
    transformedData.saveToCouchbase()

    // 关闭SparkSession和Couchbase连接对象
    spark.close()
    cluster.disconnect()
  }
}