Class IcebergTableCatalog
java.lang.Object
org.elasticsearch.xpack.esql.datasource.iceberg.IcebergTableCatalog
- All Implemented Interfaces:
Closeable,AutoCloseable,ExternalSourceFactory,TableCatalog
Iceberg table catalog implementation.
Provides metadata resolution and scan planning for Iceberg tables stored in S3.
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.elasticsearch.xpack.esql.datasources.spi.TableCatalog
TableCatalog.DataFile -
Constructor Summary
Constructors -
Method Summary
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitMethods inherited from interface org.elasticsearch.xpack.esql.datasources.spi.ExternalSourceFactory
splitProviderMethods inherited from interface org.elasticsearch.xpack.esql.datasources.spi.TableCatalog
filterPushdownSupport, operatorFactory, resolveMetadata, type
-
Constructor Details
-
IcebergTableCatalog
public IcebergTableCatalog()
-
-
Method Details
-
catalogType
- Specified by:
catalogTypein interfaceTableCatalog
-
canHandle
- Specified by:
canHandlein interfaceExternalSourceFactory- Specified by:
canHandlein interfaceTableCatalog
-
metadata
- Specified by:
metadatain interfaceTableCatalog- Throws:
IOException
-
planScan
public List<TableCatalog.DataFile> planScan(String tablePath, Map<String, Object> config, List<Object> predicates) throws IOException- Specified by:
planScanin interfaceTableCatalog- Throws:
IOException
-
close
- Specified by:
closein interfaceAutoCloseable- Specified by:
closein interfaceCloseable- Throws:
IOException
-