कैसे एक pyspark dataframe की एक पंक्ति में कॉलम का समूह की औसत खोजने के लिए और एक ही dataframe के लिए एक और स्तंभ के रूप में जोड़ने के लिए?

वोट
0

मैं प्रत्येक पंक्ति के लिए मैं के साथ शुरू स्तंभों की सेट का औसत प्राप्त करने की आवश्यकता है, जिसमें से 500 स्तंभों से मिलकर DataFrame है, country_

expr=[F.sum(train_data_df[x])/colCount for x in train_data_df.columns if 'country_' in x]
avg_train_data_df = train_data_df.withColumn('avg', *expr)

मैं निम्न त्रुटि प्रतिक्रिया मिल:

TypeError: withColumn() takes 3 positional arguments but 212 were given

19/09/2018 को 13:23
का स्रोत उपयोगकर्ता
अन्य भाषाओं में...                            

Cookies help us deliver our services. By using our services, you agree to our use of cookies. Learn more