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, HiveClientPool metaClients, java.lang.String database, java.lang.String table)

Method Summary

Modifier and Type	Method and Description
protected void	doCommit(TableMetadata base, TableMetadata metadata)
protected void	doRefresh()
protected void	doUnlock(long lockId)
FileIO	io()

Methods inherited from class org.apache.iceberg.BaseMetastoreTableOperations

commit, current, currentMetadataLocation, currentVersion, locationProvider, metadataFileLocation, refresh, refreshFromMetadataLocation, refreshFromMetadataLocation, refreshFromMetadataLocation, requestRefresh, temp, 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,
                              HiveClientPool metaClients,
                              java.lang.String database,
                              java.lang.String table)

Method Detail

io

public FileIO io()

Returns:

a FileIO to read and write table data and metadata files

doRefresh

protected void doRefresh()

Overrides:

doRefresh in class BaseMetastoreTableOperations

doCommit

protected void doCommit(TableMetadata base,
                        TableMetadata metadata)

Overrides:

doCommit in class BaseMetastoreTableOperations

doUnlock

protected void doUnlock(long lockId)
                 throws org.apache.thrift.TException,
                        java.lang.InterruptedException

Throws:

org.apache.thrift.TException

java.lang.InterruptedException