Package org.apache.drill.metastore.iceberg.schema

Class IcebergTableSchema

java.lang.Object

org.apache.drill.metastore.iceberg.schema.IcebergTableSchema

public class IcebergTableSchema
extends Object

Provides Iceberg table schema and its partition specification for specific component.

Field Summary

Fields

Modifier and Type	Field	Description
static final int	STARTING_COMPLEX_TYPES_INDEX
static final int	STARTING_SCHEMA_INDEX

Constructor Summary

Constructors

Constructor	Description
IcebergTableSchema(org.apache.iceberg.Schema tableSchema, org.apache.iceberg.PartitionSpec partitionSpec)

Method Summary

Modifier and Type	Method	Description
static IcebergTableSchema	of(Class<?> clazz, List<MetastoreColumn> partitionKeys)	Based on given class fields annotated with MetastoreFieldDefinition generates Iceberg table schema and its partition specification.
org.apache.iceberg.PartitionSpec	partitionSpec()
org.apache.iceberg.Schema	tableSchema()

Methods inherited from class java.lang.Object

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

Field Details

STARTING_SCHEMA_INDEX

public static final int STARTING_SCHEMA_INDEX

See Also:

• Constant Field Values

STARTING_COMPLEX_TYPES_INDEX

public static final int STARTING_COMPLEX_TYPES_INDEX

See Also:

• Constant Field Values

Constructor Details

IcebergTableSchema

public IcebergTableSchema(org.apache.iceberg.Schema tableSchema,
 org.apache.iceberg.PartitionSpec partitionSpec)

Method Details

of

public static IcebergTableSchema of(Class<?> clazz,
 List<MetastoreColumn> partitionKeys)

Based on given class fields annotated with MetastoreFieldDefinition generates Iceberg table schema and its partition specification.

Parameters:

clazz - base class for Iceberg schema

partitionKeys - list of partition keys

Returns:

instance of Iceberg table schema

tableSchema

public org.apache.iceberg.Schema tableSchema()

partitionSpec

public org.apache.iceberg.PartitionSpec partitionSpec()