PySpark. Операции с несколькими данными

Question

У меня есть два следующих кадра данных

Catalog:
+--------+-------+
| Type   | Value |
+========+=======+
| Cat    | 3     |
+--------+-------+
| Dog    | 2     |
+--------+-------+
| Goose  | 1     |
+--------+-------+

И

+----+-------+----------+
| ID | ITEM  | QUANTITY |
+====+=======+==========+
| 1  | CAT   | 10.0     |
+----+-------+----------+
| 1  | DOG   | 1.0      |
+----+-------+----------+
| 1  | GOOSE | 0.1      |
+----+-------+----------+
| 2  | CAT   | 0.01     |
+----+-------+----------+
| 2  | DOG   | 0.001    |
+----+-------+----------+
| 3  | GOOSE | 0.0001   |
+----+-------+----------+

Моя цель - создать следующий новый столбец

+----+-------+----------+--------+
| ID | ITEM  | QUANTITY | Value  |
+====+=======+==========+========+
| 1  | CAT   | 10.0     | 30     |
+----+-------+----------+--------+
| 1  | DOG   | 1.0      | 2      |
+----+-------+----------+--------+
| 1  | GOOSE | 0.1      | 0.1    |
+----+-------+----------+--------+
| 2  | CAT   | 0.01     | 0.03   |
+----+-------+----------+--------+
| 2  | DOG   | 0.001    | 0.002  |
+----+-------+----------+--------+
| 3  | GOOSE | 0.0001   | 0.0001 |
+----+-------+----------+--------+

Используя PySpark, я нужно умножить (или в некоторых случаях разделить) значения в столбце количества на значения в столбце значения, соответствующие элементу / типу?

Answer 1

df.show()
df1.show()

+-----+-----+
| Type|Value|
+-----+-----+
|  Cat|    3|
|  Dog|    2|
|Goose|    1| #df
+-----+-----+

+---+-----+--------+
| ID| ITEM|QUANTITY|
+---+-----+--------+
|  1|  CAT|    10.0|
|  1|  DOG|     1.0|
|  1|GOOSE|     0.1|
|  2|  CAT|    0.01|
|  2|  DOG|   0.001| #df1
|  3|GOOSE|  1.0E-4|
+---+-----+--------+

Вы можете присоединиться к upper(Type), поскольку ITEM - это все прописные буквы, а затем создать новое значение столбца, умножив *.

df1.join(df,F.expr("""ITEM=upper(Type)""")).drop("Type")\
   .withColumn("Value", F.col("Value")*F.col("QUANTITY")).orderBy("ID","ITEM").show(truncate=False)

+---+-----+--------+------+
|ID |ITEM |QUANTITY|Value |
+---+-----+--------+------+
|1  |CAT  |10.0    |30.0  |
|1  |DOG  |1.0     |2.0   |
|1  |GOOSE|0.1     |0.1   |
|2  |CAT  |0.01    |0.03  |
|2  |DOG  |0.001   |0.002 |
|3  |GOOSE|1.0E-4  |1.0E-4|
+---+-----+--------+------+