pyspark.sql.Column.eqNullSafe¶
-
列。eqNullSafe( 其他:聯盟(列,LiteralType,DecimalLiteral,DateTimeLiteral] )→列¶ -
平等為null值測試是安全的。
- 參數
-
- 其他
-
一個值或
列
筆記
不像熊貓,PySpark並不考慮NaN值是NULL。看到南語義獲取詳細信息。
例子
> > >從pyspark.sql進口行> > >df1=火花。createDataFrame([…行(id=1,價值=“foo”),…行(id=2,價值=沒有一個)…])> > >df1。選擇(…df1(“價值”]= =“foo”,…df1(“價值”]。eqNullSafe(“foo”),…df1(“價值”]。eqNullSafe(沒有一個)…)。顯示()+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - + - - - - - - - - - - - - - - - - - +|(值= foo) |(值< = > foo) | |(值< = > NULL)+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - + - - - - - - - - - - - - - - - - - +| |假| |零錯誤| | | |+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - + - - - - - - - - - - - - - - - - - +> > >df2=火花。createDataFrame([…行(價值=“酒吧”),…行(價值=沒有一個)…])> > >df1。加入(df2,df1(“價值”]= =df2(“價值”])。數()0> > >df1。加入(df2,df1(“價值”]。eqNullSafe(df2(“價值”)))。數()1> > >df2=火花。createDataFrame([…行(id=1,價值=浮動(“南”)),…行(id=2,價值=42.0),…行(id=3,價值=沒有一個)…])> > >df2。選擇(…df2(“價值”]。eqNullSafe(沒有一個),…df2(“價值”]。eqNullSafe(浮動(“南”)),…df2(“價值”]。eqNullSafe(42.0)…)。顯示()+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - + - - - - - - - - - - - - - - - - - +|(值< = > NULL) |(值< = >南)| |(值< = > 42.0)+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - + - - - - - - - - - - - - - - - - - +| | | |如此的錯誤|假|假| |真正| | | |的錯誤+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - + - - - - - - - - - - - - - - - - - +