【问题标题】:Scala filter with wildcard? [duplicate]带有通配符的Scala过滤器? [复制]
【发布时间】:2018-01-26 13:05:12
【问题描述】:

我正在尝试使用通配符进行过滤,例如:df.filter($"dst_ip"==="1.1.1.*")。不知何故,当我做df.show() 时,它返回空白。是否有关于如何对数据框进行通配符过滤的替代方法?

【问题讨论】:

    标签: scala apache-spark dataframe apache-spark-sql


    【解决方案1】:

    你为什么不使用contains

    df.filter($"dst_ip".contains("1.1.1."))
    

    或者如果你想要字符串开头,你可以像在 SQL 中一样使用like

    df.filter($"dst_ip".like("1.1.1.%"))
    

    【讨论】:

    • 谢谢!起初我不明白语法。在您的帮助下,我现在得到了它。
    猜你喜欢
    • 1970-01-01
    • 2020-06-07
    • 2017-09-05
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    • 1970-01-01
    相关资源
    最近更新 更多