“Proses Baris DataFrame Secara Paralel” Kode Jawaban

Proses Baris DataFrame Secara Paralel

def parallelize_dataframe(df, func, n_cores=4):
    df_split = np.array_split(df, n_cores)
    pool = Pool(n_cores)
    df = pd.concat(pool.map(func, df_split))
    pool.close()
    pool.join()
    return df