Hogyan lehet megtalálni az átlagos egy sor oszlop egy sorban egy pyspark dataframe és adja meg a másik oszlop azonos dataframe?

szavazat
0

Van egy DataFrame álló 500 oszlopot ki, amelyek minden egyes sort kell jutnom az átlag Az oszlopok kezdve 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)

Kapok a következő hiba válasz:

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

A kérdést 19/09/2018 13:23
a forrás felhasználó
Más nyelveken...                            

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