如何在Java代码中提供多级流水线的JavaMongoRDD？

<dependency>
    <groupId>org.mongodb</groupId>
    <artifactId>mongo-java-driver</artifactId>
    <version>3.12.10</version>
</dependency>

import com.mongodb.MongoClient;
import com.mongodb.MongoClientURI;
import com.mongodb.client.MongoDatabase;

// 创建MongoDB连接
MongoClientURI uri = new MongoClientURI("mongodb://localhost:27017");
MongoClient mongoClient = new MongoClient(uri);
MongoDatabase database = mongoClient.getDatabase("your_database_name");

import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.api.java.JavaRDD;
import com.mongodb.spark.MongoSpark;
import com.mongodb.spark.rdd.api.java.JavaMongoRDD;

// 创建JavaSparkContext
JavaSparkContext sparkContext = new JavaSparkContext(sparkConf);

// 创建JavaMongoRDD
JavaMongoRDD<Document> mongoRDD = MongoSpark.load(sparkContext).withPipeline(pipeline);

import org.bson.Document;
import com.mongodb.client.model.Aggregates;

// 定义流水线
List<Bson> pipeline = Arrays.asList(
    Aggregates.match(Filters.eq("field", "value")),
    Aggregates.group("$field", Accumulators.sum("total", "$amount"))
);

JavaMongoRDD<Document> resultRDD = mongoRDD.withPipeline(pipeline);