У меня есть два кадра данных. Я присоединяюсь к ним и делю два столбца с типом данных double
, чтобы создать новый столбец.
Я попробовал два приведенных ниже синтаксиса, оба результата приводят к нулю.
Как это исправить и в чем проблема с кодом?
df3 = df1.join(df2, cond, 'inner').select(df1[‘item’],
(df1.cost/df2.nooforders)
.alias('cost'))
df3 = df1.join(df2, cond, 'inner').withColumn(cost,(df1.cost/df2.nooforders))
nooforders sample:
7.5755
71.5975
7.4574
4.2774
0.89755
cost:
30896.98
47748.4209
5773.2718
822.12172
88348.077