如何将spark结构流写入mongodb集合？

<dependency>
    <groupId>org.mongodb.spark</groupId>
    <artifactId>mongo-spark-connector_2.12</artifactId>
    <version>3.0.1</version>
</dependency>

import org.apache.spark.sql.SparkSession
import com.mongodb.spark.MongoSpark

val spark = SparkSession.builder()
    .appName("Write Spark Structured Streaming to MongoDB")
    .master("local[*]")  // 根据你的需求设置Master URL
    .config("spark.mongodb.output.uri", "mongodb://localhost/test.collection")  // 设置MongoDB连接URI和集合名称
    .getOrCreate()

val streamData = spark.readStream
    .format("your-data-format")  // 根据你的数据格式设置
    .option("your-options", "value")  // 根据你的选项设置
    .load("your-input-path")  // 根据你的输入路径设置

val query = streamData.writeStream
    .format("mongo")  // 设置输出格式为MongoDB
    .option("database", "test")  // 设置MongoDB数据库名称
    .option("collection", "collection")  // 设置MongoDB集合名称
    .outputMode("append")  // 设置输出模式，可以是append、complete或update
    .start()

query.awaitTermination()