High Level Expressions for Dask
Project description
Dask Expressions
Dask DataFrames with query optimization.
This is a proof-of-concept rewrite of Dask DataFrame that includes query optimization and generally improved organization.
More in our blog posts:
Example
import dask_expr as dx
df = dx.datasets.timeseries()
df.head()
df.groupby("name").x.mean().compute()
Query Representation
Dask-expr encodes user code in an expression tree:
>>> df.x.mean().pprint()
Mean:
Projection: columns='x'
Timeseries: seed=1896674884
This expression tree will be optimized and modified before execution:
>>> df.x.mean().optimize().pprint()
Div:
Sum:
Fused(375f9):
| Projection: columns='x'
| Timeseries: dtypes={'x': <class 'float'>} seed=1896674884
Count:
Fused(375f9):
| Projection: columns='x'
| Timeseries: dtypes={'x': <class 'float'>} seed=1896674884
Stability
This project is a work in progress and will be changed without notice or deprecation warning. Please provide feedback, but it's best to avoid use in production settings.
API Coverage
dask_expr.DataFrame
absaddadd_prefixadd_sufixalignallanyapplyassignastypebfillclipcombine_firstcopycountcummaxcummincumprodcumsumdaskdivdividedropdrop_duplicatesdropnadtypesevalexplodeffillfillnafloordivgroupbyheadidxmaxidxminìlocindexisinisnajoinmapmap_overlapmap_partitionsmaskmaxmeanmemory_usagememory_usage_per_partitionmergeminminmodmodemulnlargestnsmallestnunique_approxpartitionspivot_tablepowprodqueryraddrdivrenamerename_axisrepartitionreplacereset_indexrfloordivrmodrmulroundrpowrsubrtruedivsampleselect_dtypesset_indexshiftshufflesort_valuesstdsubsumtailto_parquetto_timestamptruedivvarvisualizewhere
dask_expr.Series
absaddalignallanyapplyastypebetweenbfillclipcombine_firstcopycountcummaxcummincumprodcumsumdaskdivdividedrop_duplicatesdropnadtypeexplodeffillfillnafloordivgroupbyheadidxmaxidxminindexisinisnamapmap_partitionsmaskmaxmeanmemory_usagememory_usage_per_partitionminminmodmodemulnlargestnsmallestnunique_approxpartitionspowprodproductraddrdivrenamerename_axisrepartitionreplacereset_indexrfloordivrmodrmulroundrpowrsubrtruedivshiftshufflestdsubsumtailto_frameto_timestamptruedivuniquevalue_countsvarvisualizewhere
dask_expr.Index
absalignallanyapplyastypeclipcombine_firstcopycountdaskdtypefillnagroupbyheadidxmaxidxminindexisinisnamap_partitionsmaxmemory_usageminminmodenunique_approxpartitionsprodrenamerename_axisrepartitionreplacereset_indexroundshufflestdsumtailto_frameto_timestampvarvisualize
dask_expr._groupby.GroupBy
aggaggregateapply- `bfill
countffillfirstlastmaxmeanmedianminnuniqueprodshiftsizestdsumtransformvalue_countsvar
Support for SeriesGroupBy and DataFrameGroupBy.
dask_expr._resample.Resampler
aggcountfirstlastmaxmeanmedianminnuniqueohlcprodquantilesemsizestdsumvar
dask_expr._rolling.Rolling
aggapplycountmaxmeanmedianminquantilestdsumvarskewkurt
Binary operators (DataFrame, Series, and Index):
__add____radd____sub____rsub____mul____pow____rmul____truediv____rtruediv____lt____rlt____gt____rgt____le____rle____ge____rge____eq____ne____and____rand____or____ror____xor____rxor__
Unary operators (DataFrame, Series, and Index):
__invert____neg____pos__
Accessors:
CategoricalAccessorDatetimeAccessorStringAccessor
Function
concatfrom_pandasmergepivot_tableread_csvread_parquetrepartitionto_datetimeto_numericto_timedeltato_parquet
Release history Release notifications | RSS feed
Download files
Download the file for your platform. If you're not sure which to choose, learn more about installing packages.
Source Distribution
Built Distribution
File details
Details for the file dask-expr-0.3.1.tar.gz.
File metadata
- Download URL: dask-expr-0.3.1.tar.gz
- Upload date:
- Size: 119.6 kB
- Tags: Source
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/4.0.2 CPython/3.12.0
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 89e473410984c06bc1affbcb2885a09e77dab79123c6055defc206ca574a8ad4 |
|
| MD5 | 2059bb425b81581f4e37025feb1ce0a0 |
|
| BLAKE2b-256 | 35b3355af0121630bf29e05ea540e78ef60ba42a3819652a761473cd1c145b4b |
Provenance
File details
Details for the file dask_expr-0.3.1-py3-none-any.whl.
File metadata
- Download URL: dask_expr-0.3.1-py3-none-any.whl
- Upload date:
- Size: 111.5 kB
- Tags: Python 3
- Uploaded using Trusted Publishing? No
- Uploaded via: twine/4.0.2 CPython/3.12.0
File hashes
| Algorithm | Hash digest | |
|---|---|---|
| SHA256 | 13ce17b0faf9f31701fb43b7b5b4dd576a975646e8a37f192b998ee966d20730 |
|
| MD5 | b30f09b9b90d045f6d1bf8c8c0f2bd5f |
|
| BLAKE2b-256 | 407d3b73f7e1baa9288f01f97313cc81b3264061dc900dfbae3381daa5b7dd8b |
