【发布时间】:2017-03-02 10:25:38
【问题描述】:
我试图通过仅保留具有特定字符串列非空的那些行来过滤 DataFrame。
操作如下:
df.filter($"stringColumn" !== "")
我的编译器显示 !== 在我迁移到 Spark 2.0.1 后已被弃用
如何在 Spark > 2.0 中检查字符串列值是否为空?
【问题讨论】:
标签: apache-spark spark-dataframe
我试图通过仅保留具有特定字符串列非空的那些行来过滤 DataFrame。
操作如下:
df.filter($"stringColumn" !== "")
我的编译器显示 !== 在我迁移到 Spark 2.0.1 后已被弃用
如何在 Spark > 2.0 中检查字符串列值是否为空?
【问题讨论】:
标签: apache-spark spark-dataframe
使用=!= 代替:
df.filter($"stringColumn" =!= "")
【讨论】:
!==的弃用评论。
将=!= 用作“不等于”运算符
df.where(col("COLUMN_NAME") =!= "")
【讨论】: