org.apache.iceberg

Class BaseMetastoreCatalog

java.lang.Object

org.apache.iceberg.BaseMetastoreCatalog

All Implemented Interfaces:

Catalog

Direct Known Subclasses:

GlueCatalog, HadoopCatalog, HiveCatalog, NessieCatalog

public abstract class BaseMetastoreCatalog
extends java.lang.Object
implements Catalog

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
protected class	BaseMetastoreCatalog.BaseMetastoreCatalogTableBuilder

Nested classes/interfaces inherited from interface org.apache.iceberg.catalog.Catalog

Catalog.TableBuilder

Constructor Summary

Constructors

Constructor and Description
BaseMetastoreCatalog()

Method Summary

Modifier and Type	Method and Description
Catalog.TableBuilder	buildTable(TableIdentifier identifier, Schema schema) Instantiate a builder to either create a table or start a create/replace transaction.
Table	createTable(TableIdentifier identifier, Schema schema, PartitionSpec spec, java.lang.String location, java.util.Map<java.lang.String,java.lang.String> properties) Create a table.
protected abstract java.lang.String	defaultWarehouseLocation(TableIdentifier tableIdentifier)
protected static java.lang.String	fullTableName(java.lang.String catalogName, TableIdentifier identifier)
protected boolean	isValidIdentifier(TableIdentifier tableIdentifier)
Table	loadTable(TableIdentifier identifier) Load a table.
Transaction	newCreateTableTransaction(TableIdentifier identifier, Schema schema, PartitionSpec spec, java.lang.String location, java.util.Map<java.lang.String,java.lang.String> properties) Start a transaction to create a table.
Transaction	newReplaceTableTransaction(TableIdentifier identifier, Schema schema, PartitionSpec spec, java.lang.String location, java.util.Map<java.lang.String,java.lang.String> properties, boolean orCreate) Start a transaction to replace a table.
protected abstract TableOperations	newTableOps(TableIdentifier tableIdentifier)
java.lang.String	toString()

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.catalog.Catalog

createTable, createTable, createTable, dropTable, dropTable, initialize, listTables, name, newCreateTableTransaction, newCreateTableTransaction, newCreateTableTransaction, newReplaceTableTransaction, newReplaceTableTransaction, newReplaceTableTransaction, renameTable, tableExists

Constructor Detail

BaseMetastoreCatalog

public BaseMetastoreCatalog()

Method Detail

createTable

public Table createTable(TableIdentifier identifier,
                         Schema schema,
                         PartitionSpec spec,
                         java.lang.String location,
                         java.util.Map<java.lang.String,java.lang.String> properties)

Description copied from interface: Catalog

Create a table.

Specified by:

createTable in interface Catalog

Parameters:

identifier - a table identifier

schema - a schema

spec - a partition spec

location - a location for the table; leave null if unspecified

properties - a string map of table properties

Returns:

a Table instance

newCreateTableTransaction

public Transaction newCreateTableTransaction(TableIdentifier identifier,
                                             Schema schema,
                                             PartitionSpec spec,
                                             java.lang.String location,
                                             java.util.Map<java.lang.String,java.lang.String> properties)

Description copied from interface: Catalog

Start a transaction to create a table.

Specified by:

newCreateTableTransaction in interface Catalog

Parameters:

identifier - a table identifier

schema - a schema

spec - a partition spec

location - a location for the table; leave null if unspecified

properties - a string map of table properties

Returns:

a Transaction to create the table

newReplaceTableTransaction

public Transaction newReplaceTableTransaction(TableIdentifier identifier,
                                              Schema schema,
                                              PartitionSpec spec,
                                              java.lang.String location,
                                              java.util.Map<java.lang.String,java.lang.String> properties,
                                              boolean orCreate)

Description copied from interface: Catalog

Start a transaction to replace a table.

Specified by:

newReplaceTableTransaction in interface Catalog

Parameters:

identifier - a table identifier

schema - a schema

spec - a partition spec

location - a location for the table; leave null if unspecified

properties - a string map of table properties

orCreate - whether to create the table if not exists

Returns:

a Transaction to replace the table

loadTable

public Table loadTable(TableIdentifier identifier)

Description copied from interface: Catalog

Load a table.

Specified by:

loadTable in interface Catalog

Parameters:

identifier - a table identifier

Returns:

instance of Table implementation referred by tableIdentifier

buildTable

public Catalog.TableBuilder buildTable(TableIdentifier identifier,
                                       Schema schema)

Description copied from interface: Catalog

Instantiate a builder to either create a table or start a create/replace transaction.

Specified by:

buildTable in interface Catalog

Parameters:

identifier - a table identifier

schema - a schema

Returns:

the builder to create a table or start a create/replace transaction

isValidIdentifier

protected boolean isValidIdentifier(TableIdentifier tableIdentifier)

toString

public java.lang.String toString()

Overrides:

toString in class java.lang.Object

newTableOps

protected abstract TableOperations newTableOps(TableIdentifier tableIdentifier)

defaultWarehouseLocation

protected abstract java.lang.String defaultWarehouseLocation(TableIdentifier tableIdentifier)

fullTableName

protected static java.lang.String fullTableName(java.lang.String catalogName,
                                                TableIdentifier identifier)