Package org.elasticsearch.xpack.esql.datasource.iceberg

Class IcebergCatalogAdapter

java.lang.Object

org.elasticsearch.xpack.esql.datasource.iceberg.IcebergCatalogAdapter

public class IcebergCatalogAdapter
extends Object

Adapter for accessing Iceberg catalog and table metadata. Provides a simplified interface for resolving Iceberg tables.

This implementation uses Iceberg's StaticTableOperations with S3FileIO, avoiding Hadoop dependencies and security manager issues.

Constructor Summary

Constructors

Constructor	Description
IcebergCatalogAdapter()

Method Summary

Modifier and Type	Method	Description
static IcebergTableMetadata	resolveTable(String tablePath, S3Configuration s3Config)	Resolve Iceberg table metadata from a table path.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

IcebergCatalogAdapter

public IcebergCatalogAdapter()

Method Details

resolveTable

public static IcebergTableMetadata resolveTable(String tablePath,
 S3Configuration s3Config)
                                         throws Exception

Resolve Iceberg table metadata from a table path. Uses StaticTableOperations with S3FileIO instead of HadoopCatalog.

Parameters:

tablePath - the S3 path to the Iceberg table

s3Config - S3 configuration (credentials, endpoint, etc.)

Returns:

IcebergTableMetadata with resolved schema

Throws:

Exception - if table cannot be resolved