Преобразование пары RDD JavaPairRDDв JavaPairRDD

Question

Есть ли способ создать или преобразовать пару СДР из одного типа в другой.

Пример:

, если мы хотим преобразовать

JavaPairRDD<String, Double> в JavaPairRDD<Integer, Double>

здесь задача просто изменить тип ключа.

Answer 1

U можно конвертировать, как показано ниже

JavaRDD<String> words = sc.parallelize(Arrays.asList("1","2"));

JavaPairRDD<String, Double> pairRDD = words.mapToPair(s -> new Tuple2<>(s, 1.0));

JavaPairRDD<Integer, Double> pairRDD1 = pairRDD.mapToPair(f->new Tuple2<>(Integer.parseInt(f._1), 1.0));