java - Spark和Java基于两种条件过滤列

Question

我试图在我的数据帧上添加一个过滤器，由于某种原因 ||条件在 Java 中不起作用，但在 Scala 中工作得很好。该代码甚至无法编译。我们如何使用|| java中过滤条件的运算符

消息说

The operator || is undefined for the argument type(s) org.apache.spark.sql.Column, org.apache.spark.sql.Column

df.filter((df.col("eventNumbers").contains("2") )|| (df.col("eventNumbers").contains("45")))

Answer 1

首先，您必须:

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

Java 中的 scala 代码将是:

df.filter((df.col("eventNumbers").contains("2") ).or(df.col("eventNumbers").contains("45")))