dask.dataframe.rolling.map_overlap(func, df, before, after, *args, **kwargs)[source]

Apply a function to each partition, sharing rows with adjacent partitions.


Function applied to each partition.

dfdd.DataFrame, dd.Series
beforeint or timedelta

The rows to prepend to partition i from the end of partition i - 1.

afterint or timedelta

The rows to append to partition i from the beginning of partition i + 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