Advertisement
Not a member of Pastebin yet?
Sign Up,
it unlocks many cool features!
- def compute_final_dataframe(df: dd.DataFrame) -> pd.DataFrame:
- """Execute dask task graph and compute final results"""
- return (
- df
- .compute()
- .reset_index()
- .pivot(
- index='drive_time',
- columns='trip_distance',
- values='avg_amount'
- )
- .fillna(0)
- )
Advertisement
Add Comment
Please, Sign In to add comment
Advertisement