org.apache.iceberg

Class BaseMetastoreTableOperations

java.lang.Object

org.apache.iceberg.BaseMetastoreTableOperations

All Implemented Interfaces:

TableOperations

Direct Known Subclasses:

HiveTableOperations

public abstract class BaseMetastoreTableOperations
extends java.lang.Object
implements TableOperations

Field Summary

Fields

Modifier and Type	Field and Description
static java.lang.String	ICEBERG_TABLE_TYPE_VALUE
static java.lang.String	METADATA_LOCATION_PROP
static java.lang.String	PREVIOUS_METADATA_LOCATION_PROP
static java.lang.String	TABLE_TYPE_PROP

Constructor Summary

Constructors

Modifier	Constructor and Description
protected	BaseMetastoreTableOperations(org.apache.hadoop.conf.Configuration conf)

Method Summary

Modifier and Type	Method and Description
TableMetadata	current() Return the currently loaded table metadata, without checking for updates.
java.lang.String	currentMetadataLocation()
int	currentVersion()
FileIO	io()
LocationProvider	locationProvider() Returns a LocationProvider that supplies locations for new new data files.
java.lang.String	metadataFileLocation(java.lang.String filename) Given the name of a metadata file, obtain the full path of that file using an appropriate base location of the implementation's choosing.
protected void	refreshFromMetadataLocation(java.lang.String newLocation)
protected void	refreshFromMetadataLocation(java.lang.String newLocation, int numRetries)
protected void	requestRefresh()
protected java.lang.String	writeNewMetadata(TableMetadata metadata, int newVersion)

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

commit, encryption, newSnapshotId, refresh

Field Detail

TABLE_TYPE_PROP

public static final java.lang.String TABLE_TYPE_PROP

See Also:

Constant Field Values

ICEBERG_TABLE_TYPE_VALUE

public static final java.lang.String ICEBERG_TABLE_TYPE_VALUE

See Also:

Constant Field Values

METADATA_LOCATION_PROP

public static final java.lang.String METADATA_LOCATION_PROP

See Also:

Constant Field Values

PREVIOUS_METADATA_LOCATION_PROP

public static final java.lang.String PREVIOUS_METADATA_LOCATION_PROP

See Also:

Constant Field Values

Constructor Detail

BaseMetastoreTableOperations

protected BaseMetastoreTableOperations(org.apache.hadoop.conf.Configuration conf)

Method Detail

current

public TableMetadata current()

Description copied from interface: TableOperations

Return the currently loaded table metadata, without checking for updates.

Specified by:

current in interface TableOperations

Returns:

table metadata

currentMetadataLocation

public java.lang.String currentMetadataLocation()

currentVersion

public int currentVersion()

requestRefresh

protected void requestRefresh()

writeNewMetadata

protected java.lang.String writeNewMetadata(TableMetadata metadata,
                                            int newVersion)

refreshFromMetadataLocation

protected void refreshFromMetadataLocation(java.lang.String newLocation)

refreshFromMetadataLocation

protected void refreshFromMetadataLocation(java.lang.String newLocation,
                                           int numRetries)

metadataFileLocation

public java.lang.String metadataFileLocation(java.lang.String filename)

Description copied from interface: TableOperations

Given the name of a metadata file, obtain the full path of that file using an appropriate base location of the implementation's choosing.

The file may not exist yet, in which case the path should be returned as if it were to be created by e.g. FileIO.newOutputFile(String).

Specified by:

metadataFileLocation in interface TableOperations

io

public FileIO io()

Specified by:

io in interface TableOperations

Returns:

a FileIO to read and write table data and metadata files

locationProvider

public LocationProvider locationProvider()

Description copied from interface: TableOperations

Returns a LocationProvider that supplies locations for new new data files.

Specified by:

locationProvider in interface TableOperations

Returns:

a location provider configured for the current table state