代码之家 › 专栏 › 技术社区 › Masterbuilder

基于Spice和Java两种条件的过滤柱

apache-spark-sql java

Masterbuilder · 技术社区 · 6 年前

我试图在我的DATAFRAME上添加一个过滤器,由于某些原因,Java条件不在Java中工作,它在斯卡拉工作得很好。代码甚至都无法编译。在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")))

1 回复 | 直到 6 年前

rodridevops 6 年前

首先,你必须:

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

Java中的Scala代码将是:

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

推荐文章

junsung kang · Cassandra突然挂起,返回WindowsFileSystemException:“该进程不可访问,因为该文件正被另一个进程使用”

1 年前

vaibhav nalamalpu · Intellij 2023.1无法打开(即使在重新安装后)[关闭]

1 年前

Katlock · 如何在Spring中将Restpage转换为特定的对象类型?

1 年前

Edward Khazzoum · 为什么在H2数据库中创建表时出现错误4201-214?

1 年前

Yellow Blood · If语句在应为[重复]时未返回True

1 年前

user21749640 · List.contents(A)返回false,但List.contens(B)和B.equals(A)是否返回true?

1 年前

MysticSticker · 如何在savedPreferences中保存按钮[]文本

1 年前

Pektra Mom · 如何将数组中的所有字符串替换为特定的特殊字符

1 年前

Nitin Kshirsagar · 在谷歌云上将java8迁移到java11/17是强制性的吗

1 年前

changhoon seong · 为什么这个代码没有按照我想的方式输出?(关于班次)

1 年前