Package org.apache.polaris.service.catalog.iceberg

Class LocalIcebergCatalog.BasePolarisTableOperations

java.lang.Object

org.apache.polaris.service.catalog.iceberg.LocalIcebergCatalog.BasePolarisTableOperations

All Implemented Interfaces:

org.apache.iceberg.TableOperations

Enclosing class:

LocalIcebergCatalog

public class LocalIcebergCatalog.BasePolarisTableOperations
extends Object
implements org.apache.iceberg.TableOperations

An implementation of TableOperations that integrates with LocalIcebergCatalog. Much of this code was originally copied from BaseMetastoreTableOperations. CODE_COPIED_TO_POLARIS From Apache Iceberg Version: 1.8

Field Summary

Fields

Modifier and Type	Field	Description
protected org.apache.iceberg.TableMetadata	currentMetadata
protected String	currentMetadataLocation
protected static final String	METADATA_FOLDER_NAME
protected boolean	shouldRefresh
protected int	version

Method Summary

Modifier and Type	Method	Description
void	commit(org.apache.iceberg.TableMetadata base, org.apache.iceberg.TableMetadata metadata)
org.apache.iceberg.TableMetadata	current()
protected void	disableRefresh()
void	doCommit(org.apache.iceberg.TableMetadata base, org.apache.iceberg.TableMetadata metadata)
void	doRefresh()
org.apache.iceberg.io.FileIO	io()
org.apache.iceberg.io.LocationProvider	locationProvider()
String	metadataFileLocation(String filename)
protected int	parseVersion(String metadataLocation)	Parse the version from table/view metadata file name.
org.apache.iceberg.TableMetadata	refresh()
protected void	refreshFromMetadataLocation(String newLocation, Predicate<Exception> shouldRetry, int numRetries, Function<String,org.apache.iceberg.TableMetadata> metadataLoader)
protected void	requestRefresh()
org.apache.iceberg.TableOperations	temp(org.apache.iceberg.TableMetadata uncommittedMetadata)
protected String	writeNewMetadata(org.apache.iceberg.TableMetadata metadata, int newVersion)
protected org.apache.polaris.service.catalog.iceberg.LocalIcebergCatalog.MetadataWriteResult	writeNewMetadataIfRequired(boolean newTable, org.apache.iceberg.TableMetadata metadata)

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, requireStrictCleanup

Field Details

METADATA_FOLDER_NAME

protected static final String METADATA_FOLDER_NAME

See Also:

• Constant Field Values

currentMetadata

protected org.apache.iceberg.TableMetadata currentMetadata

currentMetadataLocation

protected String currentMetadataLocation

shouldRefresh

protected boolean shouldRefresh

version

protected int version

Method Details

current

public org.apache.iceberg.TableMetadata current()

Specified by:

current in interface org.apache.iceberg.TableOperations

refresh

public org.apache.iceberg.TableMetadata refresh()

Specified by:

refresh in interface org.apache.iceberg.TableOperations

commit

public void commit(org.apache.iceberg.TableMetadata base,
 org.apache.iceberg.TableMetadata metadata)

Specified by:

commit in interface org.apache.iceberg.TableOperations

io

public org.apache.iceberg.io.FileIO io()

Specified by:

io in interface org.apache.iceberg.TableOperations

metadataFileLocation

public String metadataFileLocation(String filename)

Specified by:

metadataFileLocation in interface org.apache.iceberg.TableOperations

locationProvider

public org.apache.iceberg.io.LocationProvider locationProvider()

Specified by:

locationProvider in interface org.apache.iceberg.TableOperations

doRefresh

public void doRefresh()

doCommit

public void doCommit(org.apache.iceberg.TableMetadata base,
 org.apache.iceberg.TableMetadata metadata)

temp

public org.apache.iceberg.TableOperations temp(org.apache.iceberg.TableMetadata uncommittedMetadata)

Specified by:

temp in interface org.apache.iceberg.TableOperations

writeNewMetadataIfRequired

protected org.apache.polaris.service.catalog.iceberg.LocalIcebergCatalog.MetadataWriteResult writeNewMetadataIfRequired(boolean newTable,
 org.apache.iceberg.TableMetadata metadata)

writeNewMetadata

protected String writeNewMetadata(org.apache.iceberg.TableMetadata metadata,
 int newVersion)

requestRefresh

protected void requestRefresh()

disableRefresh

protected void disableRefresh()

parseVersion

protected int parseVersion(String metadataLocation)

Parse the version from table/view metadata file name.

Parameters:

metadataLocation - table/view metadata file location

Returns:

version of the table/view metadata file in success case and -1 if the version is not parsable (as a sign that the metadata is not part of this catalog)

refreshFromMetadataLocation

protected void refreshFromMetadataLocation(String newLocation,
 Predicate<Exception> shouldRetry,
 int numRetries,
 Function<String,org.apache.iceberg.TableMetadata> metadataLoader)