我在一份用Scala编写的Spark应用程序中遇到了这个运算符,并希望理解它。例如...
val filtered = df
.filter(lower('entry) =!= "blah blah")
谢谢。我在一份用Scala编写的Spark应用程序中遇到了这个运算符,并希望理解它。例如...
val filtered = df
.filter(lower('entry) =!= "blah blah")
谢谢。org.apache.spark.sql.Column.=!=
。
def =!=(other: Any): Column
Inequality test.
// Scala: df.select( df("colA") =!= df("colB") ) df.select( !(df("colA") === df("colB")) ) // Java: import static org.apache.spark.sql.functions.*; df.filter( col("colA").notEqual(col("colB")) );
你必须使用 =!= 运算符,这样你就不仅可以将未评估的列表达式与字符串进行比较,还可以将其与评估后的值进行比较。
来源:Spark权威指南