我在用dask实现并行计算时,bag部分的pluck()方法抽取出的数据始终无法显示,是怎么回事?请高手不吝赐教,万分感谢!!!
我的代码如下:
b = db.read_text('test.json')
dict_item=b.map(json.dumps)
dict_items=dict_item.map(json.loads)
namen=dict_items.pluck('name')
namen
到这里,只输出dask.bag<pluck, npartitions=1>,并且一直都是这样的,如果用namen.compute(),又报错,说字符串的输出只能用整数下标
请坛友赐教,不胜感激!!!