在JavaPairDStream中添加tuple2值

import org.apache.spark.api.java.function.Function;
import org.apache.spark.streaming.api.java.JavaPairDStream;
import org.apache.spark.streaming.api.java.JavaStreamingContext;
import org.apache.spark.streaming.api.java.JavaDStream;
import scala.Tuple2;

public class JavaPairDStreamExample {
    public static void main(String[] args) {
        // 创建StreamingContext
        JavaStreamingContext jssc = new JavaStreamingContext(sparkConf, Durations.seconds(1));

        // 创建一个Pair DStream
        JavaPairDStream<String, Integer> pairDStream = jssc.<String, Integer>socketTextStream("localhost", 9999)
                .flatMap(line -> Arrays.asList(line.split(" ")).iterator())
                .mapToPair(word -> new Tuple2<>(word, 1))
                .reduceByKey((a, b) -> a + b);

        // 添加tuple2值
        JavaDStream<Tuple2<String, Integer>> newValues = jssc.<String, Integer>socketTextStream("localhost", 8888)
                .map(line -> {
                    String[] parts = line.split(",");
                    return new Tuple2<>(parts[0], Integer.parseInt(parts[1]));
                });

        JavaPairDStream<String, Integer> updatedDStream = pairDStream.union(newValues);

        // 打印结果
        updatedDStream.print();

        // 启动StreamingContext
        jssc.start();
        jssc.awaitTermination();
    }
}