Dask compute дает AttributeError: у объекта 'Series' нет атрибута 'encode'

Question

Я хотел бы применить функцию к каждой строке кадра данных dask.

Выполнение операции с ddf.compute() выдает ошибку:

AttributeError: 'Series' object has no attribute 'encode'

Это мой код:

def polar(data):
    data=scale(sid.polarity_scores(data.tweet)['compound'])
    return data

t_data['sentiment'] = t_data.map_partitions(polar, meta=('sentiment', int))

И использование t_data.head() также приводит к той же ошибке.

Answer 1

Вы можете использовать следующее:

t_data.apply(polar, axis=1)

Answer 2

Я узнал ответ.Вы должны подать заявку на раздел.

t_data['sentiment']=t_data.map_partitions(lambda df : df.apply(polar,axis=1))