org.apache.iceberg.hive

Class HiveTableOperations

java.lang.Object

org.apache.iceberg.BaseMetastoreTableOperations

org.apache.iceberg.hive.HiveTableOperations

All Implemented Interfaces:

TableOperations

public class HiveTableOperations
extends BaseMetastoreTableOperations

TODO we should be able to extract some more commonalities to BaseMetastoreTableOperations to avoid code duplication between this class and Metacat Tables.

Field Summary

Fields inherited from class org.apache.iceberg.BaseMetastoreTableOperations

ICEBERG_TABLE_TYPE_VALUE, METADATA_LOCATION_PROP, PREVIOUS_METADATA_LOCATION_PROP, TABLE_TYPE_PROP

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	HiveTableOperations(org.apache.hadoop.conf.Configuration conf, org.apache.iceberg.hive.HiveClientPool metaClients, java.lang.String database, java.lang.String table)

Method Summary

Modifier and Type	Method and Description
void	commit(TableMetadata base, TableMetadata metadata) Replace the base table metadata with a new version.
TableMetadata	refresh() Return the current table metadata after checking for updates.

Methods inherited from class org.apache.iceberg.BaseMetastoreTableOperations

current, currentMetadataLocation, currentVersion, io, locationProvider, metadataFileLocation, refreshFromMetadataLocation, refreshFromMetadataLocation, requestRefresh, writeNewMetadata

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.iceberg.TableOperations

encryption, newSnapshotId

Constructor Detail

HiveTableOperations

protected HiveTableOperations(org.apache.hadoop.conf.Configuration conf,
                              org.apache.iceberg.hive.HiveClientPool metaClients,
                              java.lang.String database,
                              java.lang.String table)

Method Detail

refresh

public TableMetadata refresh()

Description copied from interface: TableOperations

Return the current table metadata after checking for updates.

Returns:

table metadata

commit

public void commit(TableMetadata base,
                   TableMetadata metadata)

Description copied from interface: TableOperations

Replace the base table metadata with a new version.

This method should implement and document atomicity guarantees.

Implementations must check that the base metadata is current to avoid overwriting updates. Once the atomic commit operation succeeds, implementations must not perform any operations that may fail because failure in this method cannot be distinguished from commit failure.

Parameters:

base - table metadata on which changes were based

metadata - new table metadata with updates