在 java 中打印 JavaPairRDD<Double, Double> 的值

Question

我已将描述的结果从 Spark 决策树模型提取到 JavaPairRDD，如下所示。有人可以帮我打印 JavaPairRDD predictionAndLabel 的值吗？

JavaPairRDD<Double, Double> predictionAndLabel =
                testData.mapToPair(new PairFunction<LabeledPoint, Double, Double>() {
                    @Override
                    public Tuple2<Double, Double> call(LabeledPoint p) {
                        return new Tuple2(model.predict(p.features()), p.label());
                    }
                });

Answer 1

我不知道我是否正确回答了你的问题，但你可以这样做

    predictionAndLabel.foreach(data -> {
        System.out.println("model="+data._1() + " label=" + data._2());
    });