org.apache.iceberg.hive

Class HiveCatalog

java.lang.Object

org.apache.iceberg.BaseMetastoreCatalog

org.apache.iceberg.hive.HiveCatalog

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, Catalog

public class HiveCatalog
extends BaseMetastoreCatalog
implements java.io.Closeable

Constructor Summary

Constructors

Constructor and Description
HiveCatalog(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
void	close()
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 java.lang.String	defaultWarehouseLocation(TableIdentifier tableIdentifier)
boolean	dropTable(TableIdentifier identifier, boolean purge) Drop a table; optionally delete data and metadata files.
protected void	finalize()
Table	loadTable(TableIdentifier identifier) Load a table.
TableOperations	newTableOps(TableIdentifier tableIdentifier)
void	renameTable(TableIdentifier from, TableIdentifier to) Rename a table.

Methods inherited from class org.apache.iceberg.BaseMetastoreCatalog

dropTableData, newCreateTableTransaction, newReplaceTableTransaction

Methods inherited from class java.lang.Object

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

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

createTable, createTable, createTable, dropTable, newCreateTableTransaction, newCreateTableTransaction, newCreateTableTransaction, newReplaceTableTransaction, newReplaceTableTransaction, newReplaceTableTransaction, tableExists

Constructor Detail

HiveCatalog

public HiveCatalog(org.apache.hadoop.conf.Configuration conf)

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

Overrides:

createTable in class BaseMetastoreCatalog

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

loadTable

public Table loadTable(TableIdentifier identifier)

Description copied from interface: Catalog

Load a table.

Specified by:

loadTable in interface Catalog

Overrides:

loadTable in class BaseMetastoreCatalog

Parameters:

identifier - a table identifier

Returns:

instance of Table implementation referred by tableIdentifier

dropTable

public boolean dropTable(TableIdentifier identifier,
                         boolean purge)

Description copied from interface: Catalog

Drop a table; optionally delete data and metadata files.

If purge is set to true the implementation should delete all data and metadata files.

Specified by:

dropTable in interface Catalog

Parameters:

identifier - a table identifier

purge - if true, delete all data and metadata files in the table

Returns:

true if the table was dropped, false if the table did not exist

renameTable

public void renameTable(TableIdentifier from,
                        TableIdentifier to)

Description copied from interface: Catalog

Rename a table.

Specified by:

renameTable in interface Catalog

Parameters:

from - identifier of the table to rename

to - new table name

newTableOps

public TableOperations newTableOps(TableIdentifier tableIdentifier)

Specified by:

newTableOps in class BaseMetastoreCatalog

defaultWarehouseLocation

protected java.lang.String defaultWarehouseLocation(TableIdentifier tableIdentifier)

Specified by:

defaultWarehouseLocation in class BaseMetastoreCatalog

close

public void close()

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

finalize

protected void finalize()
                 throws java.lang.Throwable

Overrides:

finalize in class java.lang.Object

Throws:

java.lang.Throwable