We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
.read_bytes()
1 parent 2836c4a commit 4355912Copy full SHA for 4355912
pyiceberg/avro/file.py
@@ -194,8 +194,7 @@ def _read_block(self) -> int:
194
raise ValueError(f"Expected sync bytes {self.header.sync!r}, but got {sync_marker!r}")
195
block_records = self.decoder.read_int()
196
197
- block_bytes_len = self.decoder.read_int()
198
- block_bytes = self.decoder.read(block_bytes_len)
+ block_bytes = self.decoder.read_bytes()
199
if codec := self.header.compression_codec():
200
block_bytes = codec.decompress(block_bytes)
201
0 commit comments