我已经成功地从数据集中提取了特定单词的计数,但是这花费了太多时间。我是并行编程的新手。 如何在以下代码中创建并行性:
df = dd.read_csv('crime.csv',encoding="ISO-8859-1")
distinct_values = df.YEAR.unique().compute()
counter = len(distinct_values)
values_count = {}
for i in distinct_values:
count = df[df.YEAR == i].YEAR.value_counts().compute()
values_count.update(count)
list = []
for x,y in values_count.items():
dict = {}
for i in x,y:
dict['name'] = x
dict['value'] = y
# print(dict)
list.append(dict)
# print(list)
maximum = max(distinct_values)
mininmum = min(distinct_values)