函数spark java api时内部的或运算符

v8wbuo2f  于 2021-06-01  发布在  Hadoop
关注(0)|答案(1)|浏览(334)

如何在sparkjavaapi中使用或操作when函数。我想要这样的东西,但我得到一个编译器错误。

Dataset<Row> ds = ds1.withColumn("Amount2", when(ds2.col("Type").equalTo("A") Or ds2.col("Type").equalTo("B"), "Amount1").otherwise(0))

有人能给我举个例子吗。

a64a0gku

a64a0gku1#

你应该使用 or 方法:

ds2.col("Type").equalTo("A").or(ds2.col("Type").equalTo("B"))


equalTo isin 也应该起作用:

ds2.col("Type").isin("A", "B")

相关问题