2016-01-28 5 views
6

私はSparkバージョン1.4.1のPython APIを使用しています。'pyspark.sql.types.Row'からどのようにしてすべての列/属性名を取得できますか?

私の行オブジェクトは、次のようになります。

row_info = Row(name = Tim, age = 5, is_subscribed = false) 

はどのようにして、結果としてオブジェクトの属性のリストを得ることができますか?以下のような 何か:["name", "age", "is_subscribed"]

答えて

12

あなたは単にdictからこれらを抽出することができます順序を気にしない場合:

list(row_info.asDict()) 

私が直接__fields__を使用しているのを認識していますそうでない場合にのみオプション:

row_info.__fields__