Apache spark java条件替换列

Question

我试图用值Y替换数据集中的列，如果它包含X。

import org.apache.spark.sql.functions.*;

public static void main(String[] args) {
    Dataset<Row> DS;//already created dataset
    DS = DS.withColumn(column,when(col(column) === "X", "Y"));
}

它给了我Eclipse中qazxsw poi的编译错误。我不知道我做错了什么。请帮忙。