You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ro...@apache.org on 2016/12/23 04:21:20 UTC
[2/4] incubator-beam git commit: Instance variable rename.
Instance variable rename.
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/e0de5ab1
Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/e0de5ab1
Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/e0de5ab1
Branch: refs/heads/python-sdk
Commit: e0de5ab1dc706a327f914cf8ad1e1666e6289915
Parents: bbcdb12
Author: Gus Katsiapis <ka...@katsiapis-linux.mtv.corp.google.com>
Authored: Wed Dec 21 15:55:18 2016 -0800
Committer: Robert Bradshaw <ro...@gmail.com>
Committed: Thu Dec 22 20:21:00 2016 -0800
----------------------------------------------------------------------
sdks/python/apache_beam/io/avroio.py | 5 +++--
1 file changed, 3 insertions(+), 2 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-beam/blob/e0de5ab1/sdks/python/apache_beam/io/avroio.py
----------------------------------------------------------------------
diff --git a/sdks/python/apache_beam/io/avroio.py b/sdks/python/apache_beam/io/avroio.py
index b08bc83..75a9f2a 100644
--- a/sdks/python/apache_beam/io/avroio.py
+++ b/sdks/python/apache_beam/io/avroio.py
@@ -176,7 +176,7 @@ class _AvroBlock(object):
# Decompress data early on (if needed) and thus decrease the number of
# parallel copies of the data in memory at any given in time during
# block iteration.
- self._block_bytes = self._decompress_bytes(block_bytes, codec)
+ self._decompressed_block_bytes = self._decompress_bytes(block_bytes, codec)
self._num_records = num_records
self._schema = schema.parse(schema_string)
@@ -208,7 +208,8 @@ class _AvroBlock(object):
return self._num_records
def records(self):
- decoder = avroio.BinaryDecoder(StringIO.StringIO(self._block_bytes))
+ decoder = avroio.BinaryDecoder(
+ StringIO.StringIO(self._decompressed_block_bytes))
reader = avroio.DatumReader(
writers_schema=self._schema, readers_schema=self._schema)