Добавьте значения tuple2 в JavaPairDStream

Question

У меня есть JavaPairDStream<String, Tuple2<Double, Double>> со значениями,

(ADBE,(1.1,1.2))
(MSFT,(3.2,1.2))

Я хочу, чтобы значения кортежей были сложены вместе и преобразованы в JavaPairDStream<String,Double> как

(ADBE,(2.3))
(MSFT,(4.4))

Как этого добитьсяв Java Spark Streaming?

Answer 1

Предположим, что пары - это поток JavaPairDStream>:

    JavaPairDStream<String,Double> sd = pairs.mapValues((Function<Tuple2<Double, Double>, 
    Double>) v1 -> v1._1 + v1._2);

, который преобразует поток, добавляя два двойных значения к одному.