【发布时间】:2018-01-26 13:05:12
【问题描述】:
我正在尝试使用通配符进行过滤,例如:df.filter($"dst_ip"==="1.1.1.*")。不知何故,当我做df.show() 时,它返回空白。是否有关于如何对数据框进行通配符过滤的替代方法?
【问题讨论】:
标签: scala apache-spark dataframe apache-spark-sql
我正在尝试使用通配符进行过滤,例如:df.filter($"dst_ip"==="1.1.1.*")。不知何故,当我做df.show() 时,它返回空白。是否有关于如何对数据框进行通配符过滤的替代方法?
【问题讨论】:
标签: scala apache-spark dataframe apache-spark-sql
你为什么不使用contains:
df.filter($"dst_ip".contains("1.1.1."))
或者如果你想要字符串开头,你可以像在 SQL 中一样使用like:
df.filter($"dst_ip".like("1.1.1.%"))
【讨论】: