com.netflix.iceberg

Interface TableOperations

All Known Implementing Classes:

BaseMetastoreTableOperations

public interface TableOperations

SPI interface to abstract table metadata access and updates.

Method Summary

Modifier and Type	Method and Description
void	commit(TableMetadata base, TableMetadata metadata) Replace the base table metadata with a new version.
TableMetadata	current() Return the currently loaded table metadata, without checking for updates.
void	deleteFile(java.lang.String path) Delete a file.
InputFile	newInputFile(java.lang.String path) Create a new InputFile for a path.
OutputFile	newMetadataFile(java.lang.String filename) Create a new OutputFile in the table's metadata store.
long	newSnapshotId() Create a new ID for a Snapshot
TableMetadata	refresh() Return the current table metadata after checking for updates.

Method Detail

current

TableMetadata current()

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

Returns:

table metadata

refresh

TableMetadata refresh()

Return the current table metadata after checking for updates.

Returns:

table metadata

commit

void commit(TableMetadata base,
            TableMetadata metadata)

Replace the base table metadata with a new version.

This method should implement and document atomicity guarantees.

Implementations must check that the base metadata is current to avoid overwriting updates.

Parameters:

base - table metadata on which changes were based

metadata - new table metadata with updates

newInputFile

InputFile newInputFile(java.lang.String path)

Create a new InputFile for a path.

Parameters:

path - a string file path

Returns:

an InputFile instance for the path

newMetadataFile

OutputFile newMetadataFile(java.lang.String filename)

Create a new OutputFile in the table's metadata store.

Parameters:

filename - a string file name, not a full path

Returns:

an OutputFile instance for the path

deleteFile

void deleteFile(java.lang.String path)

Delete a file.

Parameters:

path - path to the file

newSnapshotId

long newSnapshotId()

Create a new ID for a Snapshot

Returns:

a long snapshot ID