Skip to content

Commit 93fbeb1

Browse files
committed
fixup! Support zstd blob decompression in Puffin
1 parent e882ba8 commit 93fbeb1

1 file changed

Lines changed: 3 additions & 2 deletions

File tree

pyiceberg/table/puffin.py

Lines changed: 3 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -72,9 +72,10 @@ def get_blob_payload(self, blob: PuffinBlobMetadata) -> bytes:
7272
raw = self._file_bytes[blob.offset : blob.offset + blob.length]
7373
if blob.compression_codec is None:
7474
return raw
75-
if blob.compression_codec == "zstd":
75+
elif blob.compression_codec == "zstd":
7676
return zstandard.ZstdDecompressor().decompress(raw)
77-
raise ValueError(f"Unsupported compression codec: {blob.compression_codec!r}")
77+
else:
78+
raise ValueError(f"Unsupported puffin compression codec: {blob.compression_codec!r}")
7879

7980
@deprecated(deprecated_in="0.12.0", removed_in="0.13.0", help_message="Use deletion_vectors_from_puffin_file(...) instead")
8081
def to_vector(self) -> dict[str, "pa.ChunkedArray"]:

0 commit comments

Comments
 (0)