Pandas parallelize for loop

import multiprocessing as mp
pool = mp.Pool(processes=mp.cpu_count())

def func( arg ):
    idx,row = arg
	# Edit df
    return row

new_rows = pool.map( func, [(idx,row) for idx,row in data_all.iterrows()])
data_all_new = pd.concat( new_rows )

Source: stackoverflow.com

Similar codes

2 votes266 views1 answer
Range python iterate by 2
Python
15 votes269 views1 answer
My python app is not quittting
Python
0 vote256 views1 answer
Python keyboard key codes
Python
0 vote264 views1 answer
Log scale seaborn
Python
12 votes264 views3 answers
Python program to add two numbers with user input
Python
0 vote255 views1 answer
Geopandas nan to 0
Python
-2 votes258 views3 answers
How to make turtle shape image smaller
Python
0 vote295 views1 answer
Createdb psql
Python
6 votes277 views2 answers
Cp python
Python
0 vote256 views1 answer
Difference between end and sep python
Python