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.

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

Constructor and Description
NessieTableOperations(com.dremio.nessie.model.ContentsKey key, org.apache.iceberg.nessie.UpdateableReference reference, com.dremio.nessie.client.NessieClient client, FileIO fileIO) Create a nessie table operations given a table identifier.

Method Summary

Modifier and Type	Method and Description
protected void	doCommit(TableMetadata base, TableMetadata metadata)
protected void	doRefresh()
FileIO	io() Returns a FileIO to read and write table data and metadata files.

Methods inherited from class org.apache.iceberg.BaseMetastoreTableOperations

commit, current, currentMetadataLocation, currentVersion, locationProvider, metadataFileLocation, refresh, refreshFromMetadataLocation, refreshFromMetadataLocation, refreshFromMetadataLocation, requestRefresh, tableName, 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

NessieTableOperations

public NessieTableOperations(com.dremio.nessie.model.ContentsKey key,
                             org.apache.iceberg.nessie.UpdateableReference reference,
                             com.dremio.nessie.client.NessieClient client,
                             FileIO fileIO)

Create a nessie table operations given a table identifier.

Method Detail

doRefresh

protected void doRefresh()

Overrides:

doRefresh in class BaseMetastoreTableOperations

doCommit

protected void doCommit(TableMetadata base,
                        TableMetadata metadata)

Overrides:

doCommit in class BaseMetastoreTableOperations

io

public FileIO io()

Description copied from interface: TableOperations

Returns a FileIO to read and write table data and metadata files.