pyspark.sql.functions.transform_keys

pyspark.sql.functions。 transform_keys ( 上校: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”:- - - - - -2.0,“酒吧”:2.0})),(“id”,“數據”))> > >df。選擇(transform_keys(…“數據”,λk,_:上(k))。別名(“data_upper”)…)。顯示(截斷=假)+ - - - - - - - - - - - - - - - - - - - - - - - - - +| data_upper |+ - - - - - - - - - - - - - - - - - - - - - - - - - +|{欄- > 2.0,FOO - > -2.0} |+ - - - - - - - - - - - - - - - - - - - - - - - - - +

以前的

pyspark.sql.functions.zip_with

下一個

pyspark.sql.functions.transform_values