Package org.apache.iceberg.nessie
Class NessieTableOperations
- java.lang.Object
-
- org.apache.iceberg.BaseMetastoreTableOperations
-
- org.apache.iceberg.nessie.NessieTableOperations
-
- All Implemented Interfaces:
TableOperations
public class NessieTableOperations extends BaseMetastoreTableOperations
Nessie implementation of Iceberg TableOperations.
-
-
Nested Class Summary
-
Nested classes/interfaces inherited from class org.apache.iceberg.BaseMetastoreTableOperations
BaseMetastoreTableOperations.CommitStatus
-
-
Field Summary
-
Fields inherited from class org.apache.iceberg.BaseMetastoreTableOperations
ICEBERG_TABLE_TYPE_VALUE, METADATA_LOCATION_PROP, PREVIOUS_METADATA_LOCATION_PROP, TABLE_TYPE_PROP
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description protected void
doCommit(TableMetadata base, TableMetadata metadata)
protected void
doRefresh()
FileIO
io()
Returns aFileIO
to read and write table data and metadata files.protected void
refreshFromMetadataLocation(java.lang.String newLocation, java.util.function.Predicate<java.lang.Exception> shouldRetry, int numRetries)
protected java.lang.String
tableName()
The full name of the table used for logging purposes only.-
Methods inherited from class org.apache.iceberg.BaseMetastoreTableOperations
checkCommitStatus, commit, current, currentMetadataLocation, currentVersion, disableRefresh, 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
-
-
-
-
Method Detail
-
tableName
protected java.lang.String tableName()
Description copied from class:BaseMetastoreTableOperations
The full name of the table used for logging purposes only. For example for HiveTableOperations it is catalogName + "." + database + "." + table.- Specified by:
tableName
in classBaseMetastoreTableOperations
- Returns:
- The full name
-
refreshFromMetadataLocation
protected void refreshFromMetadataLocation(java.lang.String newLocation, java.util.function.Predicate<java.lang.Exception> shouldRetry, int numRetries)
- Overrides:
refreshFromMetadataLocation
in classBaseMetastoreTableOperations
-
doRefresh
protected void doRefresh()
- Overrides:
doRefresh
in classBaseMetastoreTableOperations
-
doCommit
protected void doCommit(TableMetadata base, TableMetadata metadata)
- Overrides:
doCommit
in classBaseMetastoreTableOperations
-
io
public FileIO io()
Description copied from interface:TableOperations
Returns aFileIO
to read and write table data and metadata files.
-
-