AttributeError: 'DataFrame' object has no attribute 'compute'

Question

I have tried this code but this shows attribute error.

from dask.base import compute
import dask.dataframe as dd
import pandas as pd
def dfWithTripTimes(df):
    startTime=datetime.now()
    duration=df[["tpep_pickup_datetime","tpep_dropoff_datetime"]].compute()
    pickup_time=[timeToUnix(pkup) for pkuo in duration["tpep_pickup_datetime"].values]
    dropoff_time=[timeToUnix(pkup) for pkuo in duration["tpep_dropoff_datetime"].values]
    trip_Duration=(np.array(dropoff_time)-np.array(pickup_time))/float(60)
    NewFrame=df[['passanger_count','trip_distance','pickup_longitude','pickup_latitude','dropoff_longitude','dropoff_latitude']]
    NewFrame=df["trip_duration"]=trip_duration
    NewFrame=df["pickup_time"]=pickup_time
    NewFrame=df["speed"]=(NewFrame["trip_distance"]/NewFrame["Trip_Duration"])*60
    print("Time taken for creation of dataframe is {}".format(datetime.now()-startTime))
    return NewFrame
new_frame=dfWithTripTimes(data)

How is the DataFrame created? Is it a pandas DataFrame or a dask DataFrame? — Aswin Murugesh
– Aswin Murugesh, Commented Feb 27, 2019 at 5:34

MRocklin · Accepted Answer · 2019-02-27 14:58:58Z

3

Only Dask DataFrame objects have a .compute method. The error that you get is consistent with your dataframe being a Pandas DataFrame instead. If you are using Pandas then there is no need to call .compute()

answered Feb 27, 2019 at 14:58

MRocklin

57.5k29 gold badges176 silver badges245 bronze badges

Sign up to request clarification or add additional context in comments.

Collectives™ on Stack Overflow

AttributeError: 'DataFrame' object has no attribute 'compute'

1 Answer 1

Comments

Your Answer

Hot Network Questions

Collectives™ on Stack Overflow

1 Answer 1

Comments

Your Answer

Sign up or log in

Post as a guest

Related