pyspark.sql.functions.transform_values

pyspark.sql.functions。 transform_values ( 上校: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,{“它”:10.0,“銷售”:2.0,“行動”:24.0})),(“id”,“數據”))> > >df。選擇(transform_values(…“數據”,λk,v:當(k。型號(“它”,“行動”),v+10.0)。否則(v)…)。別名(“new_data”))。顯示(截斷=假)+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - +| new_data |+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - +|{行動- > 34.0 - > 20.0,銷售- > 2.0}|+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - +

以前的

pyspark.sql.functions.transform_keys

下一個

pyspark.sql.functions.map_filter