Package io.delta.kernel.internal.commit

Class DefaultFileSystemManagedTableOnlyCommitter

Object

io.delta.kernel.internal.commit.DefaultFileSystemManagedTableOnlyCommitter

All Implemented Interfaces:

Committer

public class DefaultFileSystemManagedTableOnlyCommitter
extends Object
implements Committer

Field Summary

Fields

Modifier and Type	Field	Description
static final DefaultFileSystemManagedTableOnlyCommitter	INSTANCE

Method Summary

Modifier and Type	Method	Description
CommitResponse	commit(Engine engine, CloseableIterator<Row> finalizedActions, CommitMetadata commitMetadata)	Commits the given finalizedActions and commitMetadata to the table.

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details

INSTANCE

public static final DefaultFileSystemManagedTableOnlyCommitter INSTANCE

Method Details

commit

public CommitResponse commit(Engine engine,
 CloseableIterator<Row> finalizedActions,
 CommitMetadata commitMetadata)
                      throws CommitFailedException

Description copied from interface: Committer

Commits the given finalizedActions and commitMetadata to the table.

Filesystem-managed tables: Implementations must write the finalizedActions into a new Delta JSON file at version CommitMetadata.getVersion() using atomic file operations (PUT-if-absent semantics).

Catalog-managed tables: Implementations must follow the commit rules and requirements as dictated by the managing catalog to ensure commit atomicity and consistency. This may involve:

1. Writing the finalized actions into a staged commit file
2. Calling catalog commit APIs with the staged commit location (or inline content) and additional metadata (such as the commit Protocol and Metadata)
3. Publishing ratified catalog commits into the Delta log

Specified by:

commit in interface Committer

Parameters:

engine - the Engine instance used for committing changes

finalizedActions - the iterator of finalized actions to be committed

commitMetadata - the CommitMetadata associated with this commit, which contains additional metadata required to commit the finalized actions to the table, such as the commit version, Delta log path, and more.

Returns:

CommitResponse containing the resultant commit

Throws:

CommitFailedException - if the commit operation fails