Почему __getitem__ не реализован в серии dask? - PullRequest
Новая
       9

Почему __getitem__ не реализован в серии dask?

0 голосов
/ 10 апреля 2019

У меня проблемы с работой чего-либо полезного с объектом серии dask. После того, как мне удалось его создать, я не могу работать с ним на уровне ниже, чем сам объект серии. Другими словами, я могу вычислить его и загрузить в память, а затем получить необходимые данные (dseries.compute()['x']), но в идеале мне хотелось бы что-то вроде этого: dseries['x'].compute(), поскольку для моего реального приложения dseries.compute (), скорее всего, быть слишком большим для памяти. 

import numpy as np
import pandas as pd
import dask.dataframe as ddf
import random

for i in range(5):
    pdseries = pd.Series({'x':random.randint(0,10),'y':random.randint(0,10),'z':random.randint(0,10)})
    pdseries.to_hdf(f'test{i}.hdf5','data',format='table')

dseries = ddf.read_hdf('test*.hdf5','data')

print(dseries['x'])

Это поднимает NotImplementedError. Полагаю, я ожидал, что он вернет какой-то dask-объект, который при вычислении вернул данные из файлов.

1 Ответ

1 голос
/ 10 апреля 2019

Вы должны использовать loc в этом случае. Возможно, вас заинтересует предложение или реализация getitem для серии dask, поскольку функциональность уже существует.

...