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 and Description
static int	STARTING_COMPLEX_TYPES_INDEX
static int	STARTING_SCHEMA_INDEX

Constructor Summary

Constructors

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

Method Summary

Modifier and Type	Method and 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 Detail

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 Detail

IcebergTableSchema

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

Method Detail

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()