Как обновить значение во вложенном столбце структуры с помощью pysparkPython

Программы на Python
Anonymous
Как обновить значение во вложенном столбце структуры с помощью pyspark

Сообщение Anonymous »

Я пытаюсь сделать очень просто — обновить значение вложенного столбца; однако не могу понять, как это сделать.
Среда:
  • Apache Spark 2.4.5
  • Databricks 6.4
  • Python 3.7
dataDF = [
(('Jon','','Smith'),'1580-01-06','M',3000)
]

schema = StructType([
StructField('name', StructType([
StructField('firstname', StringType(), True),
StructField('middlename', StringType(), True),
StructField('lastname', StringType(), True)
])),
StructField('dob', StringType(), True),
StructField('gender', StringType(), True),
StructField('gender', IntegerType(), True)
])

df = spark.createDataFrame(data = dataDF, schema = schema)
df = df.withColumn("name.firstname", lit('John'))
df.printSchema()
df.show()

#Results
#I get a new column instead of update

root
|-- name: struct (nullable = true)
| |-- firstname: string (nullable = true)
| |-- middlename: string (nullable = true)
| |-- lastname: string (nullable = true)
|-- dob: string (nullable = true)
|-- gender: string (nullable = true)
|-- gender: integer (nullable = true)
|-- name.firstname: string (nullable = false)

+--------------+----------+------+------+--------------+
| name| dob|gender|gender|name.firstname|
+--------------+----------+------+------+--------------+
|[Jon, , Smith]|1580-01-06| M| 3000| John|
+--------------+----------+------+------+--------------+


Подробнее здесь: https://stackoverflow.com/questions/651 ... ng-pyspark

Вернуться в «Python»