Skip to content

Commit

Permalink
Fix the arguments order in method to_deltalake called in the example (#…
Browse files Browse the repository at this point in the history
  • Loading branch information
ItSolGood committed Apr 3, 2024
1 parent 78718f1 commit 4533f53
Showing 1 changed file with 1 addition and 2 deletions.
3 changes: 1 addition & 2 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -50,7 +50,6 @@ df = ddt.read_deltalake("delta_path", datetime="2018-12-19T16:39:57-08:00")

`df` is a Dask DataFrame that you can work with in the same way you normally would. See [the Dask DataFrame documentation](https://docs.dask.org/en/stable/dataframe.html) for available operations.


### Accessing remote file systems

To be able to read from S3, azure, gcsfs, and other remote filesystems,
Expand Down Expand Up @@ -86,7 +85,7 @@ import dask_deltatable as ddt

df = dd.read_csv("s3://bucket_name/data.csv")
# do some processing on the dataframe...
ddt.to_deltalake(df, "s3://bucket_name/delta_path")
ddt.to_deltalake("s3://bucket_name/delta_path", df)
```

Writing to Delta Lake is still in development, so be aware that some features
Expand Down

0 comments on commit 4533f53

Please sign in to comment.