python dask DataFrame, support for (trivially parallelizable) row apply?
map_partitions You can apply your function to all of the partitions of your dataframe with the map_partitions function. df.map_partitions(func, columns=…) Note that func will be given only part of the dataset at a time, not the entire dataset like with pandas apply (which presumably you wouldn’t want if you want to do parallelism.) map / … Read more