From 8d7b97f7e3113d393d4caa2adb3c89661fa88390 Mon Sep 17 00:00:00 2001
From: "Sung Yun (CODE SIGNING KEY)" <sungwy@apache.org>
Date: Mon, 17 Nov 2025 22:32:44 -0500
Subject: [PATCH 1/2] explicit public apis

---
 pyiceberg/avro/__init__.py        | 5 +++++
 pyiceberg/avro/codecs/__init__.py | 7 +++++++
 pyiceberg/avro/decoder.py         | 6 +++---
 pyiceberg/avro/encoder.py         | 2 ++
 pyiceberg/avro/file.py            | 2 ++
 pyiceberg/avro/reader.py          | 2 ++
 pyiceberg/avro/resolver.py        | 2 ++
 pyiceberg/avro/writer.py          | 2 ++
 8 files changed, 25 insertions(+), 3 deletions(-)

diff --git a/pyiceberg/avro/__init__.py b/pyiceberg/avro/__init__.py
index 75440db77c..f7636590a6 100644
--- a/pyiceberg/avro/__init__.py
+++ b/pyiceberg/avro/__init__.py
@@ -21,3 +21,8 @@
 STRUCT_DOUBLE = struct.Struct("<d")  # little-endian double
 STRUCT_INT32 = struct.Struct("<i")
 STRUCT_INT64 = struct.Struct("<q")
+
+# Imported after struct constants to avoid circular imports in encoder/decoder.
+from pyiceberg.avro.file import AvroFile, AvroFileHeader, AvroOutputFile  # noqa: E402
+
+__all__ = ["AvroFile", "AvroFileHeader", "AvroOutputFile"]
diff --git a/pyiceberg/avro/codecs/__init__.py b/pyiceberg/avro/codecs/__init__.py
index f33f25f1cd..dbaf48fd68 100644
--- a/pyiceberg/avro/codecs/__init__.py
+++ b/pyiceberg/avro/codecs/__init__.py
@@ -50,3 +50,10 @@
 
 # Map to convert the naming from Iceberg to Avro
 CODEC_MAPPING_ICEBERG_TO_AVRO: dict[str, str] = {"gzip": "deflate", "zstd": "zstandard"}
+
+__all__ = [
+    "AvroCompressionCodec",
+    "AVRO_CODEC_KEY",
+    "CODEC_MAPPING_ICEBERG_TO_AVRO",
+    "KNOWN_CODECS",
+]
diff --git a/pyiceberg/avro/decoder.py b/pyiceberg/avro/decoder.py
index e971d52d48..9d83352695 100644
--- a/pyiceberg/avro/decoder.py
+++ b/pyiceberg/avro/decoder.py
@@ -17,14 +17,14 @@
 import io
 from abc import ABC, abstractmethod
 from io import SEEK_CUR
-from typing import (
-    cast,
-)
+from typing import cast
 
 from pyiceberg.avro import STRUCT_DOUBLE, STRUCT_FLOAT
 from pyiceberg.io import InputStream
 from pyiceberg.typedef import UTF8
 
+__all__: list[str] = []
+
 
 class BinaryDecoder(ABC):
     """Decodes bytes into Python physical primitives."""
diff --git a/pyiceberg/avro/encoder.py b/pyiceberg/avro/encoder.py
index 43a711fa6b..ab7a6fb743 100644
--- a/pyiceberg/avro/encoder.py
+++ b/pyiceberg/avro/encoder.py
@@ -21,6 +21,8 @@
 from pyiceberg.io import OutputStream
 from pyiceberg.typedef import UTF8
 
+__all__: list[str] = []
+
 
 class BinaryEncoder:
     """Encodes Python physical types into bytes."""
diff --git a/pyiceberg/avro/file.py b/pyiceberg/avro/file.py
index f1be9c3928..314239ec2a 100644
--- a/pyiceberg/avro/file.py
+++ b/pyiceberg/avro/file.py
@@ -50,6 +50,8 @@
 )
 from pyiceberg.utils.schema_conversion import AvroSchemaConversion
 
+__all__: list[str] = []
+
 VERSION = 1
 MAGIC = bytes(b"Obj" + bytearray([VERSION]))
 MAGIC_SIZE = len(MAGIC)
diff --git a/pyiceberg/avro/reader.py b/pyiceberg/avro/reader.py
index d33c054beb..3355857c98 100644
--- a/pyiceberg/avro/reader.py
+++ b/pyiceberg/avro/reader.py
@@ -44,6 +44,8 @@
 from pyiceberg.utils.lazydict import LazyDict
 from pyiceberg.utils.singleton import Singleton
 
+__all__: list[str] = []
+
 
 def _skip_map_array(decoder: BinaryDecoder, skip_entry: Callable[[], None]) -> None:
     """Skips over an array or map.
diff --git a/pyiceberg/avro/resolver.py b/pyiceberg/avro/resolver.py
index 900f47dab6..555d0a6501 100644
--- a/pyiceberg/avro/resolver.py
+++ b/pyiceberg/avro/resolver.py
@@ -107,6 +107,8 @@
     UUIDType,
 )
 
+__all__: list[str] = []
+
 STRUCT_ROOT = -1
 
 
diff --git a/pyiceberg/avro/writer.py b/pyiceberg/avro/writer.py
index f78d1a486e..b3e377f1f2 100644
--- a/pyiceberg/avro/writer.py
+++ b/pyiceberg/avro/writer.py
@@ -36,6 +36,8 @@
 from pyiceberg.utils.decimal import decimal_required_bytes, decimal_to_bytes
 from pyiceberg.utils.singleton import Singleton
 
+__all__: list[str] = []
+
 
 @dataclass(frozen=True)
 class Writer(Singleton):

From 6a2b03216ef7517d270e79a87722079ec3fd7b60 Mon Sep 17 00:00:00 2001
From: "Sung Yun (CODE SIGNING KEY)" <sungwy@apache.org>
Date: Mon, 17 Nov 2025 22:52:59 -0500
Subject: [PATCH 2/2] add decoder_fast to the list

---
 pyiceberg/avro/decoder_fast.pyi | 2 ++
 pyiceberg/avro/decoder_fast.pyx | 2 ++
 2 files changed, 4 insertions(+)

diff --git a/pyiceberg/avro/decoder_fast.pyi b/pyiceberg/avro/decoder_fast.pyi
index cc367c4764..58bd3a8f42 100644
--- a/pyiceberg/avro/decoder_fast.pyi
+++ b/pyiceberg/avro/decoder_fast.pyi
@@ -17,6 +17,8 @@
 
 from pyiceberg.avro.decoder import BinaryDecoder
 
+__all__: list[str] = []
+
 class CythonBinaryDecoder(BinaryDecoder):
     def __init__(self, input_contents: bytes) -> None:
         pass
diff --git a/pyiceberg/avro/decoder_fast.pyx b/pyiceberg/avro/decoder_fast.pyx
index 52caec3308..312620246c 100644
--- a/pyiceberg/avro/decoder_fast.pyx
+++ b/pyiceberg/avro/decoder_fast.pyx
@@ -23,6 +23,8 @@ from libc.stdint cimport uint64_t, int64_t
 
 import array
 
+__all__ = []
+
 
 cdef extern from "decoder_basic.c":
   void decode_zigzag_ints(const unsigned char **buffer, const uint64_t count, uint64_t *result);