Small simplification in the name-mapping (#351)

apache · Feb 2, 2024 · a4856bc · a4856bc
1 parent a983935
commit a4856bc
Showing 1 changed file with 1 addition and 4 deletions.
diff --git a/pyiceberg/io/pyarrow.py b/pyiceberg/io/pyarrow.py
@@ -811,12 +811,9 @@ def __init__(self, name_mapping: Optional[NameMapping] = None) -> None:
         self._field_names = []
         self._name_mapping = name_mapping
 
-    def _current_path(self) -> str:
-        return ".".join(self._field_names)
-
     def _field_id(self, field: pa.Field) -> int:
         if self._name_mapping:
-            return self._name_mapping.find(self._current_path()).field_id
+            return self._name_mapping.find(*self._field_names).field_id
         elif (field_id := _get_field_id(field)) is not None:
             return field_id
         else: