如何将JavaDStream转换为RDD？或者有没有办法在JavaDStream的地图函数中创建新的RDD？

import org.apache.spark.api.java.JavaRDD;
import org.apache.spark.api.java.JavaSparkContext;
import org.apache.spark.streaming.api.java.JavaDStream;
import org.apache.spark.streaming.api.java.JavaStreamingContext;

public class JavaDStreamToRDDExample {
    public static void main(String[] args) {
        // 创建Spark Streaming上下文
        JavaStreamingContext jssc = new JavaStreamingContext("local[2]", "JavaDStreamToRDDExample", Durations.seconds(1));

        // 创建JavaDStream
        JavaDStream<String> lines = jssc.socketTextStream("localhost", 9999);

        // 将JavaDStream转换为RDD
        JavaDStream<String> transformedStream = lines.transform(rdd -> {
            // 获取SparkContext
            JavaSparkContext sparkContext = rdd.context().sparkContext();

            // 创建新的RDD
            JavaRDD<String> newRDD = sparkContext.parallelize(Arrays.asList("new RDD"));

            // 返回新的JavaDStream
            return newRDD.toJavaRDD();
        });

        // 打印转换后的RDD
        transformedStream.print();

        // 启动Streaming应用程序
        jssc.start();
        try {
            jssc.awaitTermination();
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }
}