Package 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 Description protected
HiveTableOperations(org.apache.hadoop.conf.Configuration conf, HiveClientPool metaClients, java.lang.String catalogName, java.lang.String database, java.lang.String table)
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method 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 catalogName, java.lang.String database, java.lang.String table)
-
-
Method Detail
-
doRefresh
protected void doRefresh()
- Overrides:
doRefresh
in classBaseMetastoreTableOperations
-
doCommit
protected void doCommit(TableMetadata base, TableMetadata metadata)
- Overrides:
doCommit
in classBaseMetastoreTableOperations
-
doUnlock
protected void doUnlock(long lockId) throws org.apache.thrift.TException, java.lang.InterruptedException
- Throws:
org.apache.thrift.TException
java.lang.InterruptedException
-
-