java - 使用 spark 数据集中的值重复执行 java 方法

Question

我有一个方法，其中包含 if else 语句来运行基于传递给方法的字符串值的代码。

private Dataset<Row> getData(Dataset<Row> config, String controlValue) {

if (controlValue.equals(text1) {

Do this... 

} else if (controlValue.equals(text2) {

Do this... 

}

有没有办法遍历数据集的行并根据特定列的值调用 getData() 方法。

标签： javaapache-sparkmethods