dask.dataframe.rolling.map_overlap
- dask.dataframe.rolling.map_overlap(func, df, before, after, *args, **kwargs)[source]
Apply a function to each partition, sharing rows with adjacent partitions.
- Parameters
- funcfunction
Function applied to each partition.
- dfdd.DataFrame, dd.Series
- beforeint or timedelta
The rows to prepend to partition
i
from the end of partitioni - 1
.- afterint or timedelta
The rows to append to partition
i
from the beginning of partitioni + 1
.- args, kwargs
Arguments and keywords to pass to the function. The partition will be the first argument, and these will be passed after.
See also
dd.DataFrame.map_overlap