Dask Fehler: Länge des Wertes entspricht nicht Länge Index

Question

Ich habe CSV-Datei liest dask auf diese Weise mit:

import dask.dataframe as dd 
train = dd.read_csv('act_train.csv') 

Dann würde ich einfache Logik pro Zeile bewerben, die ziemlich gut in Pandas funktioniert:

columns = list(train.columns) 

for col in columns[1:]: 
    train[col] = train[col].apply(lambda x: x if x == -1 else x.split(' ')[1]) 

Leider letzte Codezeile erzeugt die folgenden Fehler: Länge von Werten entspricht nicht Länge Index

Was mache ich falsch?

Answer 1

Wenn x kein Leerzeichen enthält, wird x.split ('') eine Liste mit einem einzelnen Element x zurückgeben. Wenn Sie versuchen, auf das zweite Element von x.split ('') zuzugreifen, rufen Sie x.split ('') [1]. Es wird den Fehler geben:

"Länge der Werte stimmt nicht mit der Länge des Index überein", da kein Element bei Index 1 in x.split ('') ist.