Sparkのマップ関数でカラム名を取得する方法は？

Question

私はスパークデータフレーム（pyspark）としてワイドテーブルを持っており、すべてのセルについて、データをcolumn_name：column_name：valueの形式に変換する必要があります。マップ関数を使用しようとしていますが、列名を取得できません。これでもうまくいきません。

map_dummy(c, v): 
    return c+":"+c+":"+v 

metadata.select(*(map_dummy(c, col(c)) for c in metadata.columns)).show() 

私が望む形式にデータをどのように変換できますか？

Answer 1

あなたは組み込み関数でそれを行うことができます

：CONCATはPySpark SQLモジュールから関数である

metadata.select(concat(lit(c), lit(":"), lit(c), lit(":"), c) for c in metadata.columns)).show()