Como atualizar A coluna dinamicamente por outras colunas com base na célula valores de outra coluna

0

Pergunta

Precisamos atualizar uma coluna A , coluna B coluna C coluna ou D . A coluna que está a ser utilizado será decidido pela coluna de X que contém os valores de célula como "coluna B" ou "coluna C" ou "coluna D"

Isto é necessário pyspark dataframes

apache-spark-sql pyspark python-3.x
2021-11-23 15:00:21
1

Melhor resposta

0

Você pode usar when para conseguir isso.

Variável possible_values dentro derive_column_A() controles de todos os possíveis valores da coluna. A partir disso, construir dinamicamente uma condição para escolher a coluna apropriada.

Exemplo


from pyspark.sql import functions as F

data = [("B1", "C1", "D1", "column C"),
        ("B2", "C2", "D2", "column D"), 
        ("B3", "C3", "D3", "column B"), 
        ("B4", "C4", "D4", "column D")]

df = spark.createDataFrame(data, ("B", "C", "D", "X"))

def derive_column_A():
    possible_values = ["column B", "column C", "column D"]
    column_mapping = [{col, col.split(" ")[1]} for col in possible_values]
    condition = F
    for possible_value in possible_values:
        condition = condition.when(F.col("X") == possible_value, F.col(possible_value.split(" ")[1]))
    return condition


df.withColumn("A", derive_column_A()).show()

Saída

+---+---+---+--------+---+
|  B|  C|  D|       X|  A|
+---+---+---+--------+---+
| B1| C1| D1|column C| C1|
| B2| C2| D2|column D| D2|
| B3| C3| D3|column B| B3|
| B4| C4| D4|column D| D4|
+---+---+---+--------+---+
2021-11-23 15:48:59

Em outros idiomas

Esta página está em outros idiomas

Русский
..................................................................................................................
Italiano
..................................................................................................................
Polski
..................................................................................................................
Română
..................................................................................................................
한국어
..................................................................................................................
हिन्दी
..................................................................................................................
Français
..................................................................................................................
Türk
..................................................................................................................
Česk
..................................................................................................................
ไทย
..................................................................................................................
中文
..................................................................................................................
Español
..................................................................................................................
Slovenský
..................................................................................................................