Relative Content

Tag Archive for pysparkreplace

Replace DF input column value from dictionary in pyspark

I have a dataframe like df_1
+——+————-+———-+—–+
|KPI_ID| FORMULA|PARAMETERS|VALUE|
+——+————-+———-+—–+
| 132|131 * (1-133)| 131,133| null|
| 135| 134 * 1000| 134| null|
| 138| 137 – 139| 137,139| null|
| 143| 142 * 137| 142,137| null|
+——+————-+———-+—–+
dictionary as kpi_values:
{‘123’: ‘None’, ‘124’: ‘763.675293’, ‘125’: ‘1249.6796875’, ‘126’: ‘9313.3896484’, ‘127’: ‘14742.0’,
‘128’: ‘None’, ‘129’: ‘2.8590682’, ‘130’: ‘6010.1899414’, ‘131’: ‘2.96’, ‘133’: ‘83.3741302’, ‘134’: ‘-1.0’, ‘136’: ‘955.4359741’, ‘137’: ‘27989.8808594’, ‘139’: ‘1674.25’, ‘140’: ‘97000.0’,
‘141’: ‘2388.3144531’, ‘142’: ‘0.0’, ‘144’: ‘7421.25’, ‘145’: ‘0.0’, ‘146’: ‘1.3425742’}