dask-avro 0.3.0

功能

此项目为Dask提供Avro格式读取器。提供方便 函数读取一个或多个avro文件并对其进行任意分区。

快速启动

用法：

import dask.bag
import dask_avro

delayeds = dask_avro.read_avro("data-*.avro", blocksize=2**26)
data = dask.bag.from_delayed(delayeds)

学分

这个包是用Cookiecutter和rmax/cookiecutter-pypackage项目模板创建的。

0.3.0（2018-06-16）

• 修复了对最新版本fastavro的支持。
• 需要fastavro>=0.17。

0.2.1（2018-06-15）

• 由于中断更改，将Fastavro版本固定到<；=0.19.6。

0.2.0（2018-02-12）

• 添加了对fastavro0.16+的支持。

0.1.2（2018-02-12）

• 修复与dask0.17.0的兼容性。

0.1.1（2018-01-18）

• 将fastavro版本固定到<；0.16，因为最新版本不允许使用内部 基于c的_iter_avro函数。

0.1.0（2017-02-02）

• pypi上的第一个版本。