java - Tuple2 的 RDD 上的 Apache Spark forEach : returns one Value for all the Tuple2s in my RDD

Question

我的这段代码给了我一个意想不到的错误结果，我无法解决:

// A method that calls the collectDataRDD(logValues, rowData) method :

// ....
// my collectDataRDD(Values, rowData) method : 

问题是，当我尝试在作为 Tuple2 值的数据对象上运行 getStatus() 或 getValidationDate() 等方法时，它只为 JavaRDD 中的所有对象提供一个输出，这是错误的，因为 JavaRDD 包含多个不同的对象。然而，当我检查 tuple2 的键时，它给了我正确的结果。

我已经尝试了一切，但仍然无法弄清楚。谁能帮我解决这个问题。提前非常感谢。

Answer 1

验证是否

ticketsrdd.foreach((Tuple2<String, Data> rowData) -> {
    collectLogDataRDD(logValues, rowData);
}

是你想做的事。对每个元素一一调用此函数，在这种情况下 Tuple2 将只有一个条目。