beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From rober...@apache.org
Subject [2/4] incubator-beam git commit: Instance variable rename.
Date Fri, 23 Dec 2016 04:21:20 GMT
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 <katsiapis@katsiapis-linux.mtv.corp.google.com>
Authored: Wed Dec 21 15:55:18 2016 -0800
Committer: Robert Bradshaw <robertwb@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)
 


Mime
View raw message