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

Class IcebergTableMetadata

java.lang.Object

org.elasticsearch.xpack.esql.datasource.iceberg.IcebergTableMetadata

All Implemented Interfaces:

ExternalSourceMetadata, SourceMetadata

public class IcebergTableMetadata
extends Object
implements ExternalSourceMetadata

Metadata for an Iceberg table or Parquet file. Contains schema information resolved from Iceberg/Parquet metadata.

Constructor Summary

Constructors

Constructor	Description
IcebergTableMetadata(String tablePath, org.apache.iceberg.Schema schema, S3Configuration s3Config, String sourceType)
IcebergTableMetadata(String tablePath, org.apache.iceberg.Schema schema, S3Configuration s3Config, String sourceType, String metadataLocation)

Method Summary

Modifier and Type	Method	Description
List<Attribute>	attributes()
boolean	equals(Object o)
int	hashCode()
org.apache.iceberg.Schema	icebergSchema()	Returns the Iceberg schema for this table.
String	location()
String	metadataLocation()
S3Configuration	s3Config()
List<Attribute>	schema()
String	sourceType()
String	tablePath()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Methods inherited from interface org.elasticsearch.xpack.esql.datasources.spi.SourceMetadata

config, partitionColumns, sourceMetadata, statistics

Constructor Details

IcebergTableMetadata

public IcebergTableMetadata(String tablePath,
 org.apache.iceberg.Schema schema,
 S3Configuration s3Config,
 String sourceType)

IcebergTableMetadata

public IcebergTableMetadata(String tablePath,
 org.apache.iceberg.Schema schema,
 S3Configuration s3Config,
 String sourceType,
 String metadataLocation)

Method Details

tablePath

public String tablePath()

Specified by:

tablePath in interface ExternalSourceMetadata

attributes

public List<Attribute> attributes()

Specified by:

attributes in interface ExternalSourceMetadata

sourceType

public String sourceType()

Specified by:

sourceType in interface SourceMetadata

icebergSchema

public org.apache.iceberg.Schema icebergSchema()

Returns the Iceberg schema for this table. This is the native Iceberg schema, not the ESQL schema.

schema

public List<Attribute> schema()

Specified by:

schema in interface ExternalSourceMetadata

Specified by:

schema in interface SourceMetadata

location

public String location()

Specified by:

location in interface ExternalSourceMetadata

Specified by:

location in interface SourceMetadata

s3Config

public S3Configuration s3Config()

metadataLocation

public String metadataLocation()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object