[Feature Request] Add pyiceberg.catalog.hadoop.HadoopCatalog (filesystem-only catalog)
Nadie ha tomado este issue todavía.
Evaluación
- Dificultad
- 5/5
- Tiempo estimado
- Más de una semana
- Aptitud para principiantes
- 42/100
- Tipo de issue
- Nueva funcionalidad
- Claridad
- Bastante claro
- Estado de actividad
- Activo
- Área
- data-engineering, databases
Línea de trabajo
Empieza leyendo las implementaciones de catálogo existentes y MetastoreCatalog; después, inspecciona PyArrowFileIO._initialize_fs y el uso posterior de daft/catalog/__gravitino/__catalog.py mencionado en el issue. Compara el comportamiento solicitado con las referencias HadoopCatalog y HadoopTables de Java Iceberg. Se considera terminado cuando las operaciones de namespaces y tablas se realizan únicamente mediante el sistema de archivos, la resolución de metadatos es compatible con Java y existe una vía documentada o pública para esquemas de sistemas de archivos personalizados.
Escrito por el modelo de indexación a partir del texto del issue.
Descripción
Is your feature request related to a problem? Please describe.
Java Iceberg ships a filesystem-only HadoopCatalog / HadoopTables, where table metadata lives under <warehouse>/<db>.db/<table>/metadata/ with no external metastore. PyIceberg currently has no equivalent — the available catalog types are rest / hive / glue / dynamodb / sql / in-memory / bigquery.
This gap matters in two ways:
-
Interop with Java-side HadoopCatalog tables. Tables created by Java
HadoopCatalog(common in lightweight deployments without a metastore) cannot be opened through any supported PyIceberg catalog. Users must fall back toStaticTable.from_metadataand resolve the latestmetadata.jsonthemselves, which loses catalog semantics (no namespace listing, no create/commit). -
Downstream projects already assume the module exists. Daft's Gravitino integration imports
from pyiceberg.catalog.hadoop import HadoopCatalogand callsHadoopCatalog("gravitino_reader", props).load_table(table_dir)to open a table from a storage location (daft/catalog/__gravitino/_catalog.py). Against PyIceberg 0.11.x this raisesTypeError: HadoopCatalog.__init__() takes 2 positional arguments but 3 were given, and against versions without the module it fails at import time.
Describe the solution you'd like
A pyiceberg.catalog.hadoop.HadoopCatalog (subclassing MetastoreCatalog) implementing Java HadoopCatalog semantics:
warehouseproperty as the root location- table dir =
<warehouse>/<namespace>/<table> - metadata at
<table_dir>/metadata/v{n}.metadata.jsonplus aversion-hint.textholding the current version - latest-version resolution: read
version-hint.text, fall back to scanningmetadata/for the maxv{n}(matching Java behavior) - namespace/table create/list/commit driven purely by the warehouse filesystem (no metastore calls)
Additional context / pitfalls observed while prototyping
Happy to contribute a PR if this is in scope. A few notes from an internal prototype:
-
Metadata file naming. Java HadoopCatalog uses
v{n}.metadata.json+version-hint.text, but tables created by JDBC/REST catalogs use00000-<uuid>.metadata.jsonwith no version-hint. To open those as well, the scan fallback should accept both patterns (v(\d+)\.metadata\.jsonand\d{5}-.*\.metadata\.json), or at least document the limitation. -
Filesystem abstraction.
__init__should derive the filesystem from the catalog's FileIO (PyArrowFileIO) instead of hardcodingpyarrow.fs.HadoopFileSystem.from_uri(warehouse). The JVM-backedHadoopFileSystemonly supportshdfs://and fails for object-store schemes (s3://, and custom schemes), so routing through FileIO keeps it scheme-agnostic. -
Atomicity.
create_table/commit_tableuse create-if-absent onv{n}.metadata.jsonfor optimistic concurrency — safe on HDFS but not atomic on plain object stores (S3 has no create-if-absent guarantee). Java has the same caveat; worth documenting or using a conditional-write primitive where available.
Adapting a custom storage scheme (Tencent Cloud TBDSFS as a concrete case)
A related gap surfaced while prototyping against Tencent Cloud TBDS's distributed filesystem scheme tbdsfs://<cluster>/<path> (exposed by a Python client, plus a JVM fs.tbdsfs.impl):
-
PyArrowFileIO._initialize_fs(scheme, netloc)only understands a fixed set of schemes (hdfs / s3 / gs / file / abfs / ...), so anytbdsfs://...location raisesValueError: Unrecognized filesystem type in URI: tbdsfs. -
There is no public, documented way to plug in a custom filesystem. The only workaround today is monkey-patching a private method:
- Implement a
pyarrow.fs.FileSystemHandlersubclass wrapping the TBDSFS Python client, wrap it inpyarrow.fs.PyFileSystem, then patchPyArrowFileIO._initialize_fsto return that filesystem whenscheme == "tbdsfs". - pyarrow 21's
PyFileSystemcallback also has non-obvious contracts any custom handler must satisfy: single paths arrive as one-element lists;get_file_infomust return a one-element list; and for scheme'd URIs the netloc is prepended into the path (e.g.internal/usr/..., without a leading slash).
- Implement a
This works, but it depends on patching a private API (_initialize_fs), which is brittle across PyIceberg releases.
Suggested improvement: a documented, public extension point for registering an arbitrary pyarrow.fs.FileSystem (or a custom FileIO) per scheme — e.g. a register_file_system(scheme, factory) helper, or a scheme → FileSystem mapping read from FileIO/catalog properties — so non-standard object stores and filesystems can be integrated without touching internals. This would also naturally address the HadoopCatalog.__init__ filesystem-abstraction point above.
References
- Java:
org.apache.iceberg.hadoop.HadoopCatalog/HadoopTables - Downstream usage that currently breaks:
daft/catalog/__gravitino/_catalog.py→_open_iceberg_table
- Lenguaje dominante
- Python
- Estrellas
- 1.1k
- Forks
- 589
- Merge medio
- 2 d 2 h
- PR fusionados (30 d)
- 70
Guía de contribución
No hay ninguna guía de contribución indexada para este repositorio
Primeros pasos
- Lee el issue completo y luego la guía de contribución del proyecto.
- Comenta en el issue que vas a ocuparte — evita que dos personas hagan lo mismo.
- Haz un fork del repositorio y trabaja en una rama.
- Abre un pull request que haga referencia al número del issue.
Más de apache/iceberg-python
-
kind:bug
Dificultad 1/5 Menos de una hora Aptitud para principiantes 92/100
apache/iceberg-python#4006 ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
apache/iceberg-python#3996 ·
-
Deletion vector bitmap count is read from the blob and used as a loop bound without validation Abiertobug
Dificultad 2/5 1-3 horas Aptitud para principiantes 72/100
apache/iceberg-python#3979 ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 78/100
apache/iceberg-python#3885 ·
-
[Bug] PyArrowFileIO fails to propagate s3.ssl.ca-cert to pyarrow.fs.S3FileSystem tls_ca_file_path Abierto
Dificultad 2/5 1-3 horas Aptitud para principiantes 76/100
apache/iceberg-python#3866 · 1 comentario ·
Todos los issues de apache/iceberg-python
Issues similares
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 75/100
anthropics/skills#1811 · 1 comentario ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 75/100
speaches-ai/speaches#678 ·
-
bug
Dificultad 2/5 1-3 horas Aptitud para principiantes 75/100
datalayer/mcp-compose#42 ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 75/100
conda-forge/spacy-feedstock#177 ·
-
Dificultad 2/5 1-3 horas Aptitud para principiantes 70/100
UKGovernmentBEIS/inspect_evals#2523 ·