pyspark.sql.functions.map_filter

pyspark.sql.functions。 map_filter ( 上校:ColumnOrName,f:可調用的((pyspark.sql.column.Column,pyspark.sql.column.Column],pyspark.sql.column.Column] )→pyspark.sql.column.Column

返回一個映射的鍵-值對滿足謂詞。

參數

上校 列或str

的名字列或表達式

f 函數

一個二元函數(k:列,v:列)- >列……可以使用的方法列、函數中定義pyspark.sql.functions和ScalaUserDefinedFunctions。PythonUserDefinedFunctions不支持(火星- 27052)。

返回

列

例子

> > >df=火花。createDataFrame(((1,{“foo”:42.0,“酒吧”:1.0,“記者”:32.0})),(“id”,“數據”))> > >df。選擇(map_filter(…“數據”,λ_,v:v>30.0)。別名(“data_filtered”)…)。顯示(截斷=假)+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - +| data_filtered |+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - +| {foo巴茲- > 32.0 - > 42.0}|+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - +

以前的

pyspark.sql.functions.transform_values

下一個

pyspark.sql.functions.map_zip_with