Package org.apache.drill.metastore.iceberg.components.tables

Class IcebergTables

java.lang.Object

org.apache.drill.metastore.iceberg.components.tables.IcebergTables

All Implemented Interfaces:

Tables, IcebergMetastoreContext<TableMetadataUnit>, Operations<TableMetadataUnit>

public class IcebergTables
extends Object
implements Tables, IcebergMetastoreContext<TableMetadataUnit>

Metastore Tables component which stores tables metadata in the corresponding Iceberg table. Provides methods to read and modify tables metadata.

Field Summary

Fields

Modifier and Type	Field	Description
static IcebergTableSchema	SCHEMA

Constructor Summary

Constructors

Constructor	Description
IcebergTables(org.apache.iceberg.Table table)

Method Summary

Modifier and Type	Method	Description
IcebergMetastoreContext<TableMetadataUnit>	context()
ExpirationHandler	expirationHandler()	Returns expiration handler that expires Iceberg table metadata.
FileWriter	fileWriter()	Returns file writer which stores Metastore component data in the format supported by the FileWriter implementation.
Metadata	metadata()
Modify<TableMetadataUnit>	modify()
Read<TableMetadataUnit>	read()
org.apache.iceberg.Table	table()	Returns Iceberg table implementation used as storage for Metastore component data.
Transformer<TableMetadataUnit>	transformer()	Returns transformer instance that provides tools to transform filters, operations and data.

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.drill.metastore.components.tables.Tables

basicRequests

Field Details

SCHEMA

public static IcebergTableSchema SCHEMA

Constructor Details

IcebergTables

public IcebergTables(org.apache.iceberg.Table table)

Method Details

context

public IcebergMetastoreContext<TableMetadataUnit> context()

metadata

public Metadata metadata()

Specified by:

metadata in interface Operations<TableMetadataUnit>

Returns:

component metadata instance

read

public Read<TableMetadataUnit> read()

Specified by:

read in interface Operations<TableMetadataUnit>

Returns:

component read mechanism implementation

modify

public Modify<TableMetadataUnit> modify()

Specified by:

modify in interface Operations<TableMetadataUnit>

Returns:

component write mechanism implementation

table

public org.apache.iceberg.Table table()

Description copied from interface: IcebergMetastoreContext

Returns Iceberg table implementation used as storage for Metastore component data.

Specified by:

table in interface IcebergMetastoreContext<TableMetadataUnit>

Returns:

Iceberg table instance

fileWriter

public FileWriter fileWriter()

Description copied from interface: IcebergMetastoreContext

Returns file writer which stores Metastore component data in the format supported by the FileWriter implementation.

Specified by:

fileWriter in interface IcebergMetastoreContext<TableMetadataUnit>

Returns:

file writer instance

transformer

public Transformer<TableMetadataUnit> transformer()

Description copied from interface: IcebergMetastoreContext

Returns transformer instance that provides tools to transform filters, operations and data.

Specified by:

transformer in interface IcebergMetastoreContext<TableMetadataUnit>

Returns:

transformer instance

expirationHandler

public ExpirationHandler expirationHandler()

Description copied from interface: IcebergMetastoreContext

Returns expiration handler that expires Iceberg table metadata.

Specified by:

expirationHandler in interface IcebergMetastoreContext<TableMetadataUnit>

Returns:

expiration handler instance