Andrew aRe00t

aRe00t / groupyby_parallel.py

Created January 22, 2018 08:22 — forked from dmyersturnbull/groupyby_parallel.py

Performs a Pandas groupby operation in parallel

	# coding=utf-8

	import pandas as pd
	import itertools
	import time
	import multiprocessing
	from typing import Callable, Tuple, Union

	def groupby_parallel(groupby_df: pd.core.groupby.DataFrameGroupBy,
	func: Callable[[Tuple[str, pd.DataFrame]], Union[pd.DataFrame, pd.Series]],