Closes #946
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/4b584ca2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/4b584ca2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/4b584ca2 Branch: refs/heads/python-sdk Commit: 4b584ca26b12f42a21b25b7d72c2e57b20a1e7ad Parents: bc32bc8 f5557c0 Author: Dan Halperin <[email protected]> Authored: Tue Sep 13 09:59:56 2016 -0700 Committer: Dan Halperin <[email protected]> Committed: Tue Sep 13 09:59:56 2016 -0700 ---------------------------------------------------------------------- sdks/python/apache_beam/io/avroio.py | 252 +++++++++++++------------ sdks/python/apache_beam/io/avroio_test.py | 88 +++++++-- 2 files changed, 202 insertions(+), 138 deletions(-) ----------------------------------------------------------------------
