Случай, когда оператор для условного заполнения столбцов в pyspark
#python #apache-spark #pyspark #apache-spark-sql Вопрос: У меня есть ПиСпарк, как показано ниже: df6 = df_n_a .withColumn("x", explode_outer(col("x"))) .withColumn("y", when( col('x.e')=='S', lit(None).cast("string")) .when(col('x.e')=='C', element_at("m.n.o", -1))) .select( from_unixtime(col("x.w")).alias("w"), col("x.e").alias("e"), col("y"), ) Я…