dask-sql
dask-sql copied to clipboard
[DF] [ENH] Update limit/offset logic to reflect upstream DataFusion changes
Is your feature request related to a problem? Please describe. With #588, we have once again consolidated the logic for offsets and limits. Right now, we are computing the two separately:
- offsets are computed using a custom
map_partitionsfunction - limits are computed from the OFFSET result using
head
This can probably be consolidated, such that the custom map_partitions function also computes limits when necessary, with head only being used when no offset is specified.