

@convert.register(chunks(pd.DataFrame), pd.io.pytables.AppendableFrameTable)
def hdfstore_to_chunks_dataframes(data, chunksize=100000, **kwargs):
    if (isinstance(chunksize, (float, np.floating)) and (not chunksize.is_integer())):
        raise TypeError(('chunksize argument must be an integer, got %s' % chunksize))
    chunksize = int(chunksize)

    def f():
        k = min(chunksize, 100)
        (yield data.parent.select(data.pathname, start=0, stop=k))
        for chunk in data.parent.select(data.pathname, chunksize=chunksize, start=k):
            (yield chunk)
    return chunks(pd.DataFrame)(f)

dataset/ETHPy150Open blaze/odo/odo/backends/hdfstore.py hdfstore_to_chunks_dataframes/original