Или оператор внутри, когда функция Spark Java API - PullRequest
0 голосов
/ 10 мая 2018

Как использовать операцию Or внутри, когда функция в Spark Java API.Я хочу что-то подобное, но я получаю ошибку компилятора.

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

Может кто-нибудь подсказать мне, пожалуйста, с примером выражения.

1 Ответ

0 голосов
/ 10 мая 2018

Вы должны использовать or метод:

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

С equalTo isin также должно работать:

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